« Changelog History


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 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