'What to do during Kafka rebalance in confluent-kafka-go

Are we suppose to explicitly call IncrementalAssign/Assign and IncrementalUnassign/Unassign in the RebalanceCB? Does the same apply when NOT using the RebalanceCB and just using normal events from poll()?

go apache-kafka confluent-kafka-go

Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution	Source

'What to do during Kafka rebalance in confluent-kafka-go

Sources

Related Questions