This repository has been archived by the owner on Nov 20, 2020. It is now read-only.
0.1.15-alpha01
Pre-release
Pre-release
BUG: consumer would enter an infinite loop between offsets_out_of_range and resuming_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