All Versions
77
Latest Version
Avg Release Cycle
-
Latest Release
2193 days ago
Changelog History
Page 2
Changelog History
Page 2
-
v0.1.13-alpha02 Changes
- 0๏ธโฃ WARN: Default to use v0.10.1 of broker protocol.
- ๐จ Print client and protocol version.
-
v0.1.13-alpha01 Changes
- Consumers will continue to run if not assigned partitions.
- ๐ Fixed 'Consumer.fetchOffsets' returning no offsets when Array.empty is passed in as partitions per topic
- ๐ Fixed 'Consumer.stream' function that sometimes causes starvation when AsyncSeq.mergeAll would prioritize first few tasks rather than later
- โ Added auto versioning support for Kafka APIs for Produce, Fetch, Offset, Metadata, OffsetCommit, OffsetFetch, GroupCoordinator, JoinGroup, Heartbeat, LeaveGroup, ๐ SyncGroup, DescribeGroups, ListGroups, ApiVersions.
- โ Added an INFO message printed by connection to show protocol and client versions.
- 0๏ธโฃ Adjusted ConsumerConfig.[fetchMaxWaitMs, fetchMinBytes] to match Kafka native client defaults.
- BufferingProducer.produceBatched
-
v0.1.12 Changes
- Buffering producer experimental module.
-
v0.1.11 Changes
- โ Added support for all versions of the OffsetFetch API in the Kafka protocol.
- ๐ฅ BREAKING: Offset commit queue is moved to module
PeriodicCommitQueue
. See: https://jet.github.io/kafunk/consuming.html#Periodic-Offset-Commit. - ๐ Producer performance improvements.
- ๐ Fixed bug with producing using version >= 0.10.0 wherein empty key/value would be written
-
v0.1.10 Changes
- ๐ Fix another scenario referenced in 0.1.9 producer batching fix.
-
v0.1.9 Changes
- ๐ Fix Producer batching wherein if Producer.produceBatched was called with a batch size larger than the max, it would still send it.
-
v0.1.8 Changes
- ๐ Fix producer recovery wherein a produce batch timeout may overlap with broker connection failures, resulting in retries without rediscovery.
-
v0.1.7 Changes
- ๐ Fix Join/Sync group response for v10 and greater
-
v0.1.6 Changes
- ๐ Cumulitive release.
-
v0.1.6-rc3 Changes
- ๐ NEW: ConsumerInfo.consumerGroups returns information about all consumer groups in the cluster, including group members and the topics-partitions they are assgined.