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 <[email protected]> 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;
