Kafunk v0.1.13-alpha01 Release Notes
-
- 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