Releases: jet/kafunk
0.1.16
0.1.15-alpha04
BUG: compression works when using v0.11 (auto) protocol
0.1.15-alpha01
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
0.1.5-rc1
Added Consumer.streamRange to read a specified range of offsets.
Added Consumer.periodicOffsetCommitter which can help ensuring periodic offset commits when using Consumer.stream.
Logging improvements: changed some ERROR messages to WARN, added group coordinator to group related logs, caught missing partition info error
AsyncSeq v2.0.13
0.1.4
0.1.4-beta
Fixed v0.10.1 protocol bug for Offset API.
Fixed v0.10.1 protocol bug for JoinGroup API.
Added ApiVersionsRequest.
Added support for automatically detecting API versions via ApiVersionRequest using KafkaConfig.autoApiVersions.
0.1.3-alpha
Added ProducerResult.count indicating the number of messages produced in a batch for a partition.
0.1.2-alpha
Fixed consumer offset commit bug wherein after a rebalance a consumer gets assigned a new partition
which doesn't receive any messages for longer than the offset retention period, the offsets would be lost.
This would only happen after a rebalance not after initial join.
0.1.1-alpha
Snappy compression.
Fixed lag calculation bug in ConsumerInfo module.