Release Notes - Kafka - Version 4.1.1

Below is a summary of the JIRA issues addressed in the 4.1.1 release of Kafka. For full documentation of the release, a guide to get started, and information about the project, see the Kafka project site.

Note about upgrades: Please carefully review the upgrade documentation for this release thoroughly before upgrading your cluster. The upgrade notes discuss any critical information about incompatibilities and breaking changes, performance changes, and any other changes that might impact your production deployment of Kafka.

The documentation for the most recent release can be found at https://kafka.apache.org/documentation.html.

Improvement

  • [KAFKA-19546] - Rebalance should be triggered if the subscription is changed during group protocol downgrade triggered by static member replacement
  • [KAFKA-19747] - Improve handling of failed push telemetry request

    • Bug

  • [KAFKA-19390] - AbstractIndex#resize() does not release old mmap on Linux
  • [KAFKA-19479] - at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
  • [KAFKA-19510] - Kafka Streams does not always release lock when adding or removing threads multiple times
  • [KAFKA-19668] - processValues() must be declared as value-changing operation
  • [KAFKA-19679] - NoSuchElementException (again) in Kafka Streams iterator metrics
  • [KAFKA-19690] - Unexpected Fatal error InvalidTxnStateException on Kafka Streams (KIP-890)
  • [KAFKA-19719] - setting --no-initial-controllers flag should not validate kraft version against metadata version
  • [KAFKA-19724] - Global stream thread ignores all exceptions
  • [KAFKA-19732] - Backport KAFKA-19716 fix to 4.0 and 4.1
  • [KAFKA-19748] - Memory leak using range scans
  • [KAFKA-19758] - Weird behavior on Kafka Connect 4.1 class loading
  • [KAFKA-19760] - RecordTooLargeExceptions in group coordinator when offsets.topic.compression.codec is used
  • [KAFKA-19775] - Error if an empty topic is created when there is a regex source KS

    • Task

  • [KAFKA-15307] - Kafka Streams configuration docs outdated

    • Sub-task

  • [KAFKA-19694] - StreamsRebalanceListener is not triggered on Consumer.close()