Skip to content

v2.1.0
Compare
Choose a tag to compare
@tulios tulios released this 28 Jun 11:01
v2.1.0
df31679
This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
GPG key ID: 4AEE18F83AFDEB23
Expired
Learn about vigilant mode.

[2.1.0] - 2022-06-28

Added

  • Add pause function to eachMessage/eachBatch to pause the current topic-partition #1364
  • The KafkaMessage type is now a union between the pre-Kafka 0.10 message format and the current #1401

Fixed

  • Fix 100% CPU utilization when all brokers are unavailable #1402
  • Fix persistent error when trying to produce after a topic authorization error #1385
  • Fix error when aborting or committing an empty transaction #1388
  • Don't re-process messages from a paused partition after breaking the consumption flow #1382
Assets 2