(inlong) branch master updated: [INLONG-9807][Audit] Add debug log for audit-proxy (#9809)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 70e36029ea [INLONG-9807][Audit] Add debug log for audit-proxy (#9809)
70e36029ea is described below

commit 70e36029eafc7d7f17dac37836ee4f5df001963c
Author: doleyzi <43397300+dole...@users.noreply.github.com>
AuthorDate: Wed Mar 13 11:39:25 2024 +0800

    [INLONG-9807][Audit] Add debug log for audit-proxy (#9809)
---
 .../org/apache/inlong/audit/source/ServerMessageHandler.java     | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git 
a/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
 
b/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
index fd3064d9f5..7768ef5e8c 100644
--- 
a/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
+++ 
b/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
@@ -150,6 +150,7 @@ public class ServerMessageHandler extends 
ChannelInboundHandlerAdapter {
                 .build();
         List<AuditMessageBody> bodyList = auditRequest.getMsgBodyList();
         int errorMsgBody = 0;
+        LOGGER.debug("Receive message count: {}", 
auditRequest.getMsgBodyCount());
         for (AuditMessageBody auditMessageBody : bodyList) {
             long msgDays = messageDays(auditMessageBody.getLogTs());
             if (msgDays >= this.msgValidThresholdDays) {
@@ -173,6 +174,14 @@ public class ServerMessageHandler extends 
ChannelInboundHandlerAdapter {
             auditData.setInlongStreamId(auditMessageBody.getInlongStreamId());
             auditData.setSize(auditMessageBody.getSize());
             auditData.setAuditVersion(auditMessageBody.getAuditVersion());
+            LOGGER.debug("Receive message info: {} {} {} {} {} {} {}",
+                    auditData.getIp(),
+                    auditData.getAuditId(),
+                    auditData.getInlongGroupId(),
+                    auditData.getInlongStreamId(),
+                    auditData.getLogTs(),
+                    auditData.getSdkTs(),
+                    auditData.getCount());
 
             try {
                 byte[] body = 
GSON.toJson(auditData).getBytes(StandardCharsets.UTF_8);