Skip to content

Commit 36518f2

Browse files
committed
Added missed statement.
1 parent 9696704 commit 36518f2

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/rdkafka_cgrp.c

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3817,6 +3817,7 @@ static void rd_kafka_cgrp_op_handle_OffsetCommit(rd_kafka_t *rk,
38173817

38183818
case RD_KAFKA_RESP_ERR_STALE_MEMBER_EPOCH:
38193819
/* FIXME: Add logs.*/
3820+
rd_kafka_cgrp_consumer_expedite_next_heartbeat(rk->rk_cgrp);
38203821
if (!rd_strcmp(rko_orig->rko_u.offset_commit.reason, "manual"))
38213822
/* Don't retry manual commits giving this error.
38223823
* TODO: do this in a faster and cleaner way

0 commit comments

Comments
 (0)