[GitHub] [inlong] GanfengTan commented on issue #5745: [Improve] Align the indicator data reported to the audit module

[GitBox <gi...@apache.org>]

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: commits-unsubscribe@inlong.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org