Release Notes - Kafka - Version 3.5.2

Below is a summary of the JIRA issues addressed in the 3.5.2 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.

Bug

• [KAFKA-13197] - KStream-GlobalKTable join semantics don't match documentation
• [KAFKA-13973] - block-cache-capacity metrics worth twice as much as normal
• [KAFKA-14767] - Gradle build fails with missing commitId after git gc
• [KAFKA-14938] - Flaky test org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest#testConnectorBoundary
• [KAFKA-15091] - Javadocs for SourceTask::commit are incorrect
• [KAFKA-15100] - Unsafe to call tryCompleteFetchResponse on request timeout
• [KAFKA-15102] - Mirror Maker 2 - KIP690 backward compatibility
• [KAFKA-15106] - AbstractStickyAssignor may stuck in 3.5
• [KAFKA-15202] - MM2 OffsetSyncStore clears too many syncs when sync spacing is variable
• [KAFKA-15216] - InternalSinkRecord::newRecord method ignores the headers argument
• [KAFKA-15235] - No test coverage reports for Java due to settings for Jacoco being incompatible with Gradle 8.x
• [KAFKA-15238] - Connect workers can be disabled by DLQ-related blocking admin client calls
• [KAFKA-15243] - User creation mismatch
• [KAFKA-15263] - KRaftMigrationDriver can run the migration twice
• [KAFKA-15312] - FileRawSnapshotWriter must flush before atomic move
• [KAFKA-15319] - Upgrade rocksdb to fix CVE-2022-37434
• [KAFKA-15338] - The metric group documentation for metrics added in KAFKA-13945 is incorrect
• [KAFKA-15353] - Empty ISR returned from controller after AlterPartition request
• [KAFKA-15374] - ZK migration fails on configs for default broker resource
• [KAFKA-15375] - When running in KRaft mode, LogManager may creates CleanShutdown file by mistake
• [KAFKA-15377] - GET /connectors/{connector}/tasks-config endpoint exposes externalized secret values
• [KAFKA-15391] - Delete topic may lead to directory offline
• [KAFKA-15429] - Kafka Streams attempts to commit on a closed producer when shutting down after an exception when running with EOS
• [KAFKA-15450] - Disable ZK migration when JBOD configured
• [KAFKA-15487] - CVE-2023-40167, CVE-2023-36479 - Upgrade jetty to 9.4.52, 10.0.16, 11.0.16, 12.0.1
• [KAFKA-15498] - Upgrade Snappy-Java to 1.1.10.4
• [KAFKA-15502] - Handle large keystores in SslEngineValidator
• [KAFKA-15552] - Duplicate Producer ID blocks during ZK migration
• [KAFKA-15571] - StateRestoreListener#onRestoreSuspended is never called because wrapper DelegatingStateRestoreListener doesn't implement onRestoreSuspended
• [KAFKA-15602] - Breaking change in 3.4.0 ByteBufferSerializer
• [KAFKA-15607] - Possible NPE is thrown in MirrorCheckpointTask
• [KAFKA-15693] - Disabling scheduled rebalance delay in Connect can lead to indefinitely unassigned connectors and tasks
• [KAFKA-15755] - LeaveGroupResponse v0-v2 should handle no members
• [KAFKA-15771] - ProduceRequest#partitionSizes() is not an atomic operation
• [KAFKA-15800] - Malformed connect source offsets corrupt other partitions with DataException

Task

• [KAFKA-15378] - Rolling upgrade system tests are failing
• [KAFKA-15664] - Add 3.4.0 streams upgrade/compatibility tests

Test

• [KAFKA-15211] - DistributedConfigTest#shouldFailWithInvalidKeySize fails when run after TestSslUtils#generate
• [KAFKA-15393] - MirrorMaker2 integration tests are shutting down uncleanly