- [Feature] Introduce ability to react to
#eof
either from#consume
or from#eofed
when EOF without new messages. - [Enhancement] Provide
Consumer#eofed?
to indicate reaching EOF. - [Enhancement] Always immediately report on
inconsistent_group_protocol
error. - [Enhancement] Reduce virtual partitioning to 1 partition when any partitioner execution in a partitioned batch crashes.
- [Enhancement] Provide
KARAFKA_REQUIRE_RAILS
to disable default Railsrequire
to run Karafka without Rails despite having Rails in the Gemfile. - [Enhancement] Increase final listener recovery from 1 to 60 seconds to prevent constant rebalancing. This is the last resort recovery and should never happen unless critical errors occur.