All Versions
77
Latest Version
Avg Release Cycle
-
Latest Release
1518 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.