You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/09/28 11:14:15 UTC
[inlong] branch release-1.3.0 updated: [INLONG-6052][DataProxy] wrong value set in PulsarClientService (#6053)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/release-1.3.0 by this push:
new ec03cbb86 [INLONG-6052][DataProxy] wrong value set in PulsarClientService (#6053)
ec03cbb86 is described below
commit ec03cbb86e60b89faa11afbde65f15654029ddd2
Author: Goson Zhang <46...@qq.com>
AuthorDate: Wed Sep 28 19:13:37 2022 +0800
[INLONG-6052][DataProxy] wrong value set in PulsarClientService (#6053)
---
.../org/apache/inlong/dataproxy/sink/pulsar/PulsarClientService.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/PulsarClientService.java b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/PulsarClientService.java
index 6510bce57..bf4558313 100644
--- a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/PulsarClientService.java
+++ b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/pulsar/PulsarClientService.java
@@ -139,9 +139,9 @@ public class PulsarClientService {
boolean result;
final String pkgVersion =
event.getHeaders().get(ConfigConstants.MSG_ENCODE_VER);
- final String inlongStreamId =
- event.getHeaders().get(AttributeConstants.GROUP_ID);
final String inlongGroupId =
+ event.getHeaders().get(AttributeConstants.GROUP_ID);
+ final String inlongStreamId =
event.getHeaders().get(AttributeConstants.STREAM_ID);
try {
producerInfo = getProducerInfo(poolIndex, topic, inlongGroupId, inlongStreamId);