decaton
decaton copied to clipboard
Adopt poll(Duration) fixes #118
Summary
- Currently, Decaton uses
KafkaConsumer#poll(long)
which is deprecated and could be removed in future Kafka release
Seems like there's behavior change regarding rebalance-listener invocation. Needs consideration how to address that.
I'll address this in another PR to fix #98. Closing this PR for now