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