From 0be6ff46fdae0c24b79e9ea2d55cd062b9bcc6ce Mon Sep 17 00:00:00 2001 From: wzl12356 Date: Thu, 6 Jan 2022 10:27:45 +0800 Subject: [PATCH] kafka: set meta uninit when task failed --- src/protocol/KafkaMessage.cc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/protocol/KafkaMessage.cc b/src/protocol/KafkaMessage.cc index 862094b1..ebc87b7d 100644 --- a/src/protocol/KafkaMessage.cc +++ b/src/protocol/KafkaMessage.cc @@ -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));