breeze/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-02-08 01:33:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1241 from kedixa/dev

Browse Source 
kafkabugfix: OffsetCommit parse and SyncGroup encode makes bad message
This commit is contained in:
xiehan
2023-03-31 17:32:47 +08:00
committed by GitHub
parent 7bb7a8c5e0 9f4a576478
commit d92b170030
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/protocol/KafkaMessage.cc
View File

@@ -2611,10 +2611,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();
@@ -3625,7 +3622,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));