[Bug Report]: KafkaFlow doesn't work with cooperative-sticky
protocol
#456
Labels
bug
Something isn't working
cooperative-sticky
protocol
#456
Prerequisites
Description
As discussed in this thread KafkaFlow doesn't behave correctly when the consumer is configured to use
cooperative-sticky
rebalancing protocol.The protocol is described here
Steps to reproduce
Configure the consumer using
WithConsumerConfig(...)
and set the the strategy:Expected behavior
The consumer is expected to work as usual/normal, except that rebalancing would not cause "stop-the-world" behaviour.
Actual behavior
When KafkaFlow is configured to use
PartitionAssignmentStrategy.CooperativeSticky
the consumer seems to be working (processes messages), but does not commit any offsets.KafkaFlow version
2.4.1
The text was updated successfully, but these errors were encountered: