Skip to content

Commit

Permalink
[KIP-848] Fix reading error code in CGH_leave due to incorrect parsin…
Browse files Browse the repository at this point in the history
…g of the response. (#4691)
  • Loading branch information
pranavrth authored Apr 17, 2024
1 parent 88b6839 commit 427e8cc
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions src/rdkafka_cgrp.c
Original file line number Diff line number Diff line change
Expand Up @@ -930,8 +930,7 @@ rd_kafka_cgrp_handle_ConsumerGroupHeartbeat_leave(rd_kafka_t *rk,
goto err;
}

if (request->rkbuf_reqhdr.ApiVersion >= 1)
rd_kafka_buf_read_throttle_time(rkbuf);
rd_kafka_buf_read_throttle_time(rkbuf);

rd_kafka_buf_read_i16(rkbuf, &ErrorCode);

Expand Down

0 comments on commit 427e8cc

Please sign in to comment.