When appRebalanceEnable == true and rebalanceCb == nil and channel == nil, we want handle the event by poll , so the rebalance event should return by poll but not nil.
link:
|
if channel != nil && c.appRebalanceEnable && c.rebalanceCb == nil { |
fix example:
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().
return ev
}
When
appRebalanceEnable == true and rebalanceCb == nil and channel == nil, we want handle the event bypoll, so the rebalance event should return bypollbut not nil.link:
confluent-kafka-go/kafka/consumer.go
Line 1029 in 1b46fb9
fix example: