GanfengTan commented on issue #5745:
URL: https://github.com/apache/inlong/issues/5745#issuecomment-1232355064
@gosonzhang @EMsnap @dockerzhang @healchow Hi guys, I have an idea for the
question.
The reason :
1. The reads and writes are asynchronous and the times are randomly
generated for audit data.
2. The DataProxy compresses data and the times are randomly generated for
audit data.
Anwser to the question:
1. Uniformly defined as data collection time.
2. The DataProxy gets data collection time and report to audit data for
Non-compression data.
Update code Java Bean
The data of message:
public interface Message {
byte[] getBody();
Map<String, String> getHeader();
}
To
public interface Message {
byte[] getBody();
Map<String, String> getHeader();
Long getTime;
}
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
