All Versions
77
Latest Version
Avg Release Cycle
-
Latest Release
2193 days ago

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.