Merge pull request #961 from Barenboim/master

set kafka response's correlation id when parsing
sogou · Jun 24, 2022 · 635a1e5 · 635a1e5
2 parents 669d46e + 0f61875
commit 635a1e5
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/protocol/KafkaMessage.cc b/src/protocol/KafkaMessage.cc
@@ -2803,11 +2803,13 @@ int KafkaResponse::parse_response()
 
  void *buf = this->parser->msgbuf;
  size_t size = this->parser->message_size;
- int correlation_id;
+ int32_t correlation_id;
 
  if (parse_i32(&buf, &size, &correlation_id) < 0)
  return -1;
 
+ this->correlation_id = correlation_id;
+
  int ret = it->second(&buf, &size);
 
  if (ret < 0)