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/08/26 04:59:24 UTC
[inlong] 02/09: [INLONG-5667][SDK] Change groupId and streamId while wrapping message (#5668)
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
commit 7e5400e195f7ce24254e722752267fc798d8766c
Author: xueyingzhang <86...@users.noreply.github.com>
AuthorDate: Wed Aug 24 16:48:33 2022 +0800
[INLONG-5667][SDK] Change groupId and streamId while wrapping message (#5668)
---
inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/base/pack_queue.cc | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/base/pack_queue.cc b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/base/pack_queue.cc
index 50b39d417..09d70282a 100644
--- a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/base/pack_queue.cc
+++ b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/base/pack_queue.cc
@@ -40,7 +40,7 @@ namespace dataproxy_sdk
{
data_ = new char[data_capacity_];
memset(data_, 0x0, data_capacity_);
- topic_desc_ = "inlong_group_id=" + inlong_group_id_ + "&inlong_stream_id=" + inlong_stream_id_;
+ topic_desc_ = "groupId=" + inlong_group_id_ + "&streamId=" + inlong_stream_id_;
first_use_ = Utils::getCurrentMsTime();
last_use_ = Utils::getCurrentMsTime();
data_time_ = 0;