From 18b8a9c71bda617e5fc0fcbd0de877f32612bf4e Mon Sep 17 00:00:00 2001 From: Aryan Rahar Date: Thu, 4 Sep 2025 12:05:36 +0000 Subject: [PATCH] consumer: return rebalance event via Poll() when appRebalanceEnable && no RebalanceCb (fixes #1457) --- kafka/consumer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/consumer.go b/kafka/consumer.go index efc54d00e..51a4d2d03 100644 --- a/kafka/consumer.go +++ b/kafka/consumer.go @@ -1026,7 +1026,7 @@ func (c *Consumer) handleRebalanceEvent(channel chan Event, rkev *C.rd_kafka_eve } - if channel != nil && c.appRebalanceEnable && c.rebalanceCb == nil { + if c.appRebalanceEnable && c.rebalanceCb == nil { // Channel-based consumer with rebalancing enabled, // return the rebalance event and rely on the application // to call *Assign() / *Unassign().