Kafunk v0.1.15-alpha01 Release Notes
Release Date: 2018-03-05 // about 6 years ago-
- BUG: consumer would enter an infinite loop between
offsets_out_of_range
andresuming_fetch_from_reset_offsets
- ๐ BUG: stalled consumers after TCP connection timeout
- ๐ BUG: offsets committed for partitions which are no longer assigned after a rebalance
- ๐ FEATURE: ConsumerConfig.fetchMaxBytesOverride allows increasing fetchMaxBytes to a ceiling on message too big exceptions.
- IMPROVE: logging where received_empty_buffer logged as INFO message as it doesn't indicate an error
- ๐ IMPROVE: connection managemeng to ensure only a single TCP connection per broker per Kafka connection
- ๐ IMPROVE: Reduce recovery time from broker restarts and rebalancing
- BUG: consumer would enter an infinite loop between