GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-19 21:56:21 +08:00
Code Issues Packages Projects Releases Wiki Activity

kafkabugfix: OffsetCommit parse and SyncGroup encode makes bad message

Browse Source
This commit is contained in:
kedixa
2023-03-31 17:31:26 +08:00
parent d597423bb7
commit d3cdace4c2
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/protocol/KafkaMessage.cc
+1 -4
View File
@@ -2653,10 +2653,7 @@ int KafkaRequest::encode_syncgroup(struct iovec vectors[], int max)
}
}
else
{
append_i32(this->msgbuf, 0);
append_bytes(this->msgbuf, "");
}
this->cur_size = this->msgbuf.size();
@@ -3667,7 +3664,7 @@ int KafkaResponse::parse_offsetcommit(void **buf, size_t *size)
int32_t partition_cnt;
int32_t partition;
if (this->api_version >= 1)
if (this->api_version >= 3)
CHECK_RET(parse_i32(buf, size, &throttle_time));
CHECK_RET(parse_i32(buf, size, &topic_cnt));