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

kafka: set meta uninit when task failed

Browse Source
This commit is contained in:
wzl12356
2022-01-06 10:27:45 +08:00
parent 80ec6110fb
commit 0be6ff46fd
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/protocol/KafkaMessage.cc
+2 -2
View File
@@ -44,7 +44,7 @@ namespace protocol
#define CHECK_RET(exp) if (exp < 0) return exp
#ifndef htonll
static int64_t htonll(int64_t x)
static uint64_t htonll(uint64_t x)
{
if (1 == htonl(1))
return x;
@@ -3500,7 +3500,7 @@ int KafkaResponse::parse_joingroup(void **buf, size_t *size)
CHECK_RET(parse_string(buf, size, &cgroup->leader_id));
CHECK_RET(parse_string(buf, size, &cgroup->member_id));
CHECK_RET(kafka_cgroup_parse_member(buf, size, &this->cgroup,
&this->meta_list,
&this->meta_list,
&this->alien_meta_list,
this->api_version));