This is an automated email from the ASF dual-hosted git repository. gosonzhang pushed a commit to branch INLONG-8507 in repository https://gitbox.apache.org/repos/asf/inlong.git
commit 9896b6e0a7034646556219e8f6a8eb8c63685543 Author: gosonzhang <[email protected]> AuthorDate: Wed Jul 12 11:40:19 2023 +0800 [INLONG-8507][Dataproxy]Modify nodeIp in dataproxy message to clientIp --- .../org/apache/inlong/dataproxy/source/httpMsg/HttpMessageHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/httpMsg/HttpMessageHandler.java b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/httpMsg/HttpMessageHandler.java index 94245e2628..9d6b4710ca 100644 --- a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/httpMsg/HttpMessageHandler.java +++ b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/httpMsg/HttpMessageHandler.java @@ -326,7 +326,7 @@ public class HttpMessageHandler extends SimpleChannelInboundHandler<FullHttpRequ strBuff.append("groupId=").append(groupId) .append("&streamId=").append(streamId) .append("&dt=").append(dataTime) - .append("&NodeIP=").append(clientIp) + .append("&clientIp=").append(clientIp) .append("&cnt=").append(strMsgCount) .append("&rt=").append(msgRcvTime) .append(AttributeConstants.SEPARATOR).append(AttributeConstants.MSG_RPT_TIME)
