Apache Kafka 3.0.0 Release Summary: New Features, Improvements, Bugs, Tasks, and Tests

Kafka 3.0.0 was released on September 21, 2021. The release includes many important changes such as deprecation of Java 8 and Scala 2.12 support, Raft‑based metadata quorum with snapshot support, stronger delivery guarantees for the default producer, removal of message formats v0 and v1, optimized OffsetFetch and FindCoordinator requests, more flexible MirrorMaker 2 configuration and deprecation of MirrorMaker 1, the ability to restart connector tasks in a single Connect call, default‑enabled connector log context and client overrides, enhanced timestamp semantics in Kafka Streams, public API changes to Stream TaskId, default serde set to null, and other improvements.

New Features

[KAFKA-8863] - Add InsertHeader and DropHeaders connector transforms KIP-145
[KAFKA-12471] - Implement createPartitions in KIP-500 mode
[KAFKA-13207] - If a partition is removed from the sampler, the replica fetcher should not update partition state on divergence

Improvements

[KAFKA-3745] - Consider adding connector key to ValueJoiner interface
[KAFKA-4793] - Kafka Connect: POST /connectors/{name}/restart does not start failed tasks
[KAFKA-5235] - GetOffsetShell: support multiple topics and consumer config overrides
[KAFKA-6987] - Re‑implement KafkaFuture with CompletableFuture
[KAFKA-7458] - Avoid forced processing during bootstrap
[KAFKA-8326] - Add Serde> support
[KAFKA-8372] - Remove deprecated RocksDB#compactRange API
[KAFKA-8478] - Poll more messages before forced processing
[KAFKA-8531] - Change default replica configuration
[KAFKA-8613] - Enforce grace period for window operations in streams
[KAFKA-8897] - Upgrade RocksDB version
[KAFKA-9559] - Change default serde from ByteArraySerde to null
[KAFKA-9726] - MM2 mimics MM1 IdentityReplicationPolicy
[KAFKA-10062] - Add method to retrieve current timestamp known to Streams applications
[KAFKA-10201] - Update codebase to use more inclusive terminology
[KAFKA-10449] - Connect‑distributed sample config lacks listeners description
[KAFKA-10585] - Kafka Streams should clean up state store directories
[KAFKA-10619] - Producer default enables EOS
[KAFKA-10675] - ConnectSchema.validateValue() error messages should include schema name
[KAFKA-10697] - Delete ProduceResponse.response
[KAFKA-10746] - Consumer vote timeout expiry should be logged as WARNING instead of INFO
[KAFKA-10767] - Add unit test cases for missing methods in ThreadCacheTest
[KAFKA-10769] - Delete JoinGroupRequest#containsValidPattern as it duplicates Topic#containsValidPattern
[KAFKA-10885] - Refactor MemoryRecordsBuilderTest/MemoryRecordsTest to avoid many ignored test cases
[KAFKA-12177] - Retention is not idempotent
[KAFKA-12234] - Extend OffsetFetch request to accept multiple group IDs
[KAFKA-12287] - Add WARN log when resetting offsets by timestamp or duration, default to latest
[KAFKA-12288] - Delete task‑level filesystem lock
[KAFKA-12294] - Consider using forwarding mechanism to create metadata auto‑topic
[KAFKA-12313] - Consider deprecating default.windowed.serde.inner.class config
[KAFKA-12329] - Better error message when a topic does not exist for kafka-reassign-partitions
[KAFKA-12335] - Upgrade JUnit from 5.7.0 to 5.7.1
[KAFKA-12344] - Support SlidingWindows in Scala API
[KAFKA-12347] - Improve Kafka Streams progress tracking capability
[KAFKA-12349] - Follow up on PartitionEpoch issue in KIP‑500
[KAFKA-12362] - Determine whether a task is idle
[KAFKA-12379] - KIP‑716: Allow configuring offset sync topic location in MirrorMaker2
[KAFKA-12396] - Provide dedicated exception for empty key in kstreams
[KAFKA-12398] - Fix flaky test ConsumerBounceTest.testClose
[KAFKA-12408] - Documentation omits ReplicaManager metrics
[KAFKA-12409] - ReplicaManager metric leakage
[KAFKA-12415] - Prepare for Gradle 7.0, limit transitive range of non‑api dependencies
[KAFKA-12419] - Remove deprecated Kafka Streams API in 3.0
[KAFKA-12436] - Deprecate MirrorMaker v1
[KAFKA-12439] - When in KIP‑500 mode, allow assigning new partitions to fenced nodes
[KAFKA-12442] - Upgrade ZSTD JNI from 1.4.8‑4 to 1.4.9‑1
[KAFKA-12454] - Add ERROR log on kafka‑log‑dirs when given broker IDs do not exist in the cluster
[KAFKA-12464] - Strengthen constraint‑based sticky allocation algorithm
[KAFKA-12479] - Merge partition offset requests in ConsumerGroupCommand into a single request
[KAFKA-12483] - Enable client rewrite feature by default in connector config
[KAFKA-12484] - Enable connector log context by default in Connect
[KAFKA-12499] - Adjust transaction timeout based on Streams EOS commit interval
[KAFKA-12509] - Tighten StateDirectory thread locking
[KAFKA-12541] - Extend ListOffset to fetch offsets for max timestamp
[KAFKA-12573] - Remove deprecated Metric#value
[KAFKA-12574] - Deprecate eos‑alpha
[KAFKA-12577] - Remove deprecated ConfigEntry constructor
[KAFKA-12584] - Remove deprecated Sum and Total classes
[KAFKA-12591] - Remove deprecated quota.producer.default and quota.consumer.default configs
[KAFKA-12612] - Delete checksum from ConsumerRecord/RecordMetadata in 3.0
[KAFKA-12614] - Use Jenkinsfile for building trunk and release branches
[KAFKA-12620] - Producer IDs generated by controller
[KAFKA-12637] - Delete deprecated PartitionAssignor interface
[KAFKA-12662] - Add unit tests for ProducerPerformance
[KAFKA-12663] - Update FindCoordinator to resolve multiple coordinators at once
[KAFKA-12675] - Improve scalability and performance of sticky general allocator
[KAFKA-12779] - TaskMetadata should return actual TaskId instead of plain string
[KAFKA-12788] - Improve KRaft replica placement
[KAFKA-12803] - Support partition reassignment in KRaft mode
[KAFKA-12819] - Improve test quality of life
[KAFKA-12849] - Consider migrating TaskMetadata to internal interface
[KAFKA-12874] - Increase default consumer session timeout to 45 seconds (KIP‑735)
[KAFKA-12906] - Consumer should include partition and offset in deserialization exception
[KAFKA-12909] - Allow users to opt‑in to fake left/right stream joins improvements
[KAFKA-12921] - Upgrade ZSTD JNI from 1.4.9‑1 to 1.5.0‑1
[KAFKA-12922] - MirrorCheckpointTask should close topic filter
[KAFKA-12931] - KIP‑746: modify KRaft metadata records
[KAFKA-12934] - Move some controller classes to metadata package
[KAFKA-12981] - Ensure LogSegment.maxTimestampSoFar and LogSegment.offsetOfMaxTimestampSoFar are read/updated synchronously
[KAFKA-13000] - Improve handling of UnsupportedVersionException in MockClient
[KAFKA-13021] - Improve Javadocs for API changes and resolve follow‑up issues of KIP‑633
[KAFKA-13026] - Idempotent producer (KAFKA‑10619) follow‑up tests
[KAFKA-13041] - Support debugging system tests with ducker‑ak
[KAFKA-13209] - Upgrade jetty‑server to fix CVE‑2021‑34429
[KAFKA-13258] - AlterClientQuotas response failure should not include error
[KAFKA-13259] - DescribeProducers response failure should not include error
[KAFKA-13260] - FindCoordinator error count does not handle v4 issue

Bugs

[KAFKA-3968] - New FileMessageSet flush does not fsync() parent directory
[KAFKA-5146] - Kafka Streams: delete compile dependency on connect‑json
[KAFKA-6435] - Application reset tool may delete incorrect internal topics
[KAFKA-7421] - Kafka Connect deadlock when loading classes
[KAFKA-8315] - Historical join issue
[KAFKA-8562] - Despite KAFKA‑5051, SASL_SSL still performs reverse DNS lookup
[KAFKA-8784] - Delete default implementation of RocksDBConfigSetter#close
[KAFKA-8940] - Flaky SmokeTestDriverIntegrationTest.shouldWorkWithRebalance
[KAFKA-9186] - Kafka Connect logs possibly fake error messages from DelegatingClassLoader
[KAFKA-9189] - Close blocked when Zookeeper connection is lost
[KAFKA-9295] - KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable
[KAFKA-9527] - NPE in application reset tool when using --input-topics with empty partitions
[KAFKA-9672] - ISR death broker causes isr‑expiration failure and exception
[KAFKA-9858] - CVE‑2016‑3189 use‑after‑free in bzip2recover leads to DoS
[KAFKA-10046] - Ignore deprecated PartitionGrouper config
[KAFKA-10192] - Flaky BlockingConnectorTest#testBlockInConnectorStop
[KAFKA-10340] - Source connector should report error when sending to non‑existent topic
[KAFKA-10614] - Group coordinator onElection/onResignation should prevent leader epoch
[KAFKA-12170] - Connect Cast cannot correctly handle "byte" type fields
[KAFKA-12252] - Distributed herder tick thread loops fast when worker loses leadership
[KAFKA-12262] - New session key not distributed when follower with key becomes leader
[KAFKA-12297] - MockProducer implementation contradicts async send Callback docs
[KAFKA-12303] - Flatten SMT drops some fields when encountering null values
[KAFKA-12308] - ConfigDef.parseType deadlock
[KAFKA-12330] - FetchSessionCache may starve partitions when FetchResponse is full
[KAFKA-12336] - Custom stream naming does not work when calling stream[K, V](topicPattern: Pattern)
[KAFKA-12350] - Documentation incorrect about refresh.themes.interval.seconds default
[KAFKA-12393] - Multi‑tenant documentation notes
[KAFKA-12426] - Missing logic to create partition.metadata file in RaftReplicaManager
[KAFKA-12427] - Broker does not close silently idle connections with buffered data
[KAFKA-12474] - Worker dies if new session key cannot be written
[KAFKA-12492] - RocksDBConfigSetter example formatting broken
[KAFKA-12514] - NPE in SubscriptionState
[KAFKA-12520] - Producer state unnecessarily rebuilt on startup
[KAFKA-12522] - Cast SMT should allow null‑value messages through
[KAFKA-12548] - Invalid record error message not sent to application
[KAFKA-12557] - KafkaAdminClientTest#testClientSideTimeoutAfterFailureToReceiveResponse intermittently hangs
[KAFKA-12611] - Fix incorrect random payload usage in ProducerPerformance
[KAFKA-12619] - Ensure LeaderChange messages are committed before initializing high watermark
[KAFKA-12650] - NPE in InternalTopicManager#cleanUpCreatedTopics
[KAFKA-12655] - CVE‑2021‑28165 – upgrade jetty to 9.4.39
[KAFKA-12660] - Offset commit sensor not updated after append failure
[KAFKA-12661] - ConfigEntry#equals does not compare other fields when value is non‑null
[KAFKA-12667] - Incorrect error log when closing StateDirectory
[KAFKA-12672] - test‑kraft‑server‑start fails
[KAFKA-12677] - raftCluster always sends to wrong active controller and never updates
[KAFKA-12684] - Successful partition list incorrectly replaced by erroneous list
[KAFKA-12686] - Race condition in AlterIsr response handling
[KAFKA-12691] - TaskMetadata timeSinceIdlingStarted not reported correctly
[KAFKA-12700] - admin.listeners config values documented oddly
[KAFKA-12702] - Unhandled exception in InterBrokerSendThread
[KAFKA-12718] - Session windows close prematurely
[KAFKA-12730] - Single Kerberos login failure from Java 9 onward causes all future connections to fail
[KAFKA-12747] - Flaky RocksDBStoreTest.shouldReturnUUIDsWithStringPrefix
[KAFKA-12749] - Suppressed update log topic config missing on KTable
[KAFKA-12752] - CVE‑2021‑28168 – upgrade jersey to 2.34 or 3.02
[KAFKA-12754] - TaskMetadata endOffsets not updated when reading offsets
[KAFKA-12777] - AutoTopicCreationManager does not handle response errors
[KAFKA-12782] - Javadocs search sends to non‑existent URL
[KAFKA-12792] - Fix metric errors and introduce TimelineInteger
[KAFKA-12815] - KTable.transformValue may have incorrect record metadata
[KAFKA-12835] - Topic ID may mismatch across brokers after protocol version upgrade
[KAFKA-12851] - Flaky RaftEventSimulationTest.canMakeProgressIfMajorityIsReachable
[KAFKA-12856] - Upgrade Jackson to 2.12.3
[KAFKA-12865] - Admin Client API documentation error when describing ACLs
[KAFKA-12866] - Kafka still requires ZK root permission even with chroot
[KAFKA-12867] - Trogdor ConsumeBenchWorker exits early when maxMessages configured
[KAFKA-12870] - RecordAccumulator stalls in flushing state
[KAFKA-12880] - Delete deprecated Count and SampledTotal in 3.0
[KAFKA-12889] - Log cleanup group should consider empty log segments to avoid leaving empty logs
[KAFKA-12890] - Consumer group stalls in "CompletingRebalance"
[KAFKA-12896] - Group rebalance loop caused by duplicate GroupJoinGroups
[KAFKA-12897] - KRaft controller cannot create topics with multiple partitions on a single‑broker cluster
[KAFKA-12898] - Owned partitions in subscription must be sorted
[KAFKA-12904] - Connect validation REST endpoint uses incorrect timeout
[KAFKA-12914] - StreamSourceNode.toString() throws with StreamsBuilder.stream(Pattern) ctor
[KAFKA-12925] - Missing prefixScan in intermediate interface
[KAFKA-12926] - ConsumerGroupCommand NPE when running kafka‑consumer‑groups.sh with negative numbers
[KAFKA-12945] - Delete port, host.name and related configs in 3.0
[KAFKA-12948] - NetworkClient.close(node) makes NetworkClient unusable when node is connected
[KAFKA-12949] - TestRaftServer scala.MatchError: null on test‑kraft‑server‑start.sh
[KAFKA-12951] - Infinite loop when restoring GlobalKTable
[KAFKA-12964] - Corrupted segment recovery deletes new producer state snapshots
[KAFKA-12983] - onJoinPrepare not always called before joining group
[KAFKA-12984] - Cooperative sticky allocator gets stuck on invalid SubscriptionState input metadata
[KAFKA-12991] - Fix unsafe access to `AbstractCoordinator.state`
[KAFKA-12993] - Streams "memory management" documentation formatting broken
[KAFKA-12996] - OffsetOutOfRange not handled correctly when fetched offset is less than leader's start offset
[KAFKA-13002] - listOffsets must downgrade immediately for non‑MAX_TIMESTAMP specs
[KAFKA-13003] - KafkaBroker advertises socket port instead of configured public port
[KAFKA-13007] - KafkaAdminClient getListOffsetsCalls creates cluster snapshot per topic partition
[KAFKA-13008] - Stream stops processing data for long time while waiting for partition lag
[KAFKA-13010] - Flaky org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectCommittedOffsetInformation
[KAFKA-13029] - FindCoordinators batch may break consumers during rolling upgrade
[KAFKA-13033] - Coordinator unavailable error should be added to cancel‑mapping list for new lookups
[KAFKA-13037] - "Thread state already PENDING_SHUTDOWN" log spam
[KAFKA-13053] - KRaft record Bump framework version
[KAFKA-13056] - Broker should not generate snapshots when controller co‑exists
[KAFKA-13057] - Many broker RPCs not enabled in KRaft mode
[KAFKA-13058] - `AlterConsumerGroupOffsetsHandler` cannot handle partition errors correctly
[KAFKA-13073] - MockLog implementation inconsistency causes test failures
[KAFKA-13078] - Prematurely close FileRawSnapshotWriter
[KAFKA-13080] - Snapshot request not directed to controller in kraft
[KAFKA-13092] - Performance regression in LISR requests
[KAFKA-13096] - QueryableStoreProvider does not update when adding/removing/replacing threads, making IQ impossible
[KAFKA-13098] - No such file exception when restoring snapshot in metadata log directory
[KAFKA-13099] - TransactionalIds expiry leads to message too large error
[KAFKA-13100] - Controller cannot recover to in‑memory snapshot
[KAFKA-13104] - Controller should notify RaftClient on resignation
[KAFKA-13112] - Controller commit offset out of sync with raft client listener context
[KAFKA-13119] - Validate KRaft controllerListener config on startup
[KAFKA-13127] - Fix partition lookup logic deviation
[KAFKA-13129] - Fix broken system test related to ConfigCommand changes
[KAFKA-13132] - Upgrade to topic ID in LISR request introduces gap in 3.0
[KAFKA-13137] - KRaft Controller Metric MBean name reference incorrect
[KAFKA-13139] - Empty response after restart request for connector with no tasks causes NPE
[KAFKA-13141] - Leader should not update follower offset fetch during divergence
[KAFKA-13143] - Disable metadata endpoint of KRaft controller
[KAFKA-13160] - Fix code that passes expected default resource name to config handler when using KRaft
[KAFKA-13161] - Follower leader and ISR state not updated after partition changes in KRaft
[KAFKA-13167] - Broker should heartbeat immediately during shutdown
[KAFKA-13168] - KRaft observer should not have a replica ID
[KAFKA-13173] - KRaft controller cannot correctly handle simultaneous broker expirations
[KAFKA-13198] - TopicsDelta does not update deleted topics when handling PartitionChangeRecord
[KAFKA-13214] - Consumer should not reset group state after disconnect
[KAFKA-13215] - Flaky org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectEndOffsetInformation
[KAFKA-13219] - BrokerState metrics not working in KRaft clusters
[KAFKA-13262] - Mock client now has final close() method
[KAFKA-13266] - `InitialFetchState` should be created after removing fetcher from partition
[KAFKA-13270] - Kafka may fail to connect to Zookeeper, retry forever, never start
[KAFKA-13276] - Public DescribeConsumerGroupsResult constructor points to KafkaFutureImpl
[KAFKA-13277] - Serialization of long label strings in request/response can cause BufferOverflowException

Tasks

[KAFKA-8405] - Delete deprecated `kafka-preferred-replica-election` command
[KAFKA-8734] - Delete PartitionAssignorAdapter and deprecated PartitionAssignor interface
[KAFKA-10070] - Parameterize connector unit tests to remove code duplication
[KAFKA-10091] - Improve task idleness handling
[KAFKA-12482] - Delete deprecated rest.host.name and rest.port Connect worker config
[KAFKA-12519] - Consider deleting old built‑in metrics version for streams
[KAFKA-12578] - Delete deprecated security classes/methods
[KAFKA-12579] - Remove various deprecated methods from 3.0 client
[KAFKA-12581] - Delete deprecated Admin.electPreferredLeaders
[KAFKA-12588] - Delete deprecated --zookeeper flag in shell commands
[KAFKA-12590] - Delete deprecated SimpleAclAuthorizer
[KAFKA-12592] - Delete deprecated LogConfig.Compact
[KAFKA-12600] - Delete deprecated client.dns.lookup config value "default"
[KAFKA-12625] - Fix notification file
[KAFKA-12717] - Delete internal transformer config properties
[KAFKA-12724] - Add 2.8.0 to system tests and stream upgrade tests
[KAFKA-12794] - Trailing JSON token in DescribeProducersRequest.json may cause parser errors
[KAFKA-12800] - Configure Jackson to reject trailing input in generators
[KAFKA-12820] - Upgrade maven‑artifact dependency to resolve CVE‑2021‑26291
[KAFKA-12976] - Remove UNSUPPORTED_VERSION error from delete‑topic calls
[KAFKA-12985] - CVE‑2021‑28169 – upgrade jetty to 9.4.42
[KAFKA-13035] - Update POST /connectors/{name}/restart docs to include task restart behavior
[KAFKA-13051] - Define Principal Serde for 3.0
[KAFKA-13151] - Disallow policy config in KRaft

Tests

[KAFKA-9009] - MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete
[KAFKA-12273] - InterBrokerSendThread#pollOnce throws FatalExitError even when closed correctly
[KAFKA-12284] - MirrorConnectorsIntegrationSSLTest.testOneWayReplicationWithAutoOffsetSync
[KAFKA-12384] - ListOffsetsRequestTest.testResponseIncludesLeaderEpoch
[KAFKA-12561] - Fix RaftClusterTest.testCreateClusterAndCreateListDeleteTopic()
[KAFKA-12629] - Failing RaftClusterTest
[KAFKA-13045] - Add test for batch OffsetFetch request with duplicate group entries

Sub‑tasks

[KAFKA-7106] - Remove segment/segmentInterval from Window definition
[KAFKA-7606] - Remove deprecated options from StreamsResetter
[KAFKA-7785] - Remove PartitionGrouper interface and its config, move DefaultPartitionGrouper to internal package
[KAFKA-9548] - SPI – RemoteStorageManager and RemoteLogMetadataManager interfaces and related classes
[KAFKA-10292] - Fix flaky streams/streams_broker_bounce_test.py
[KAFKA-10434] - Delete deprecated methods on WindowStore
[KAFKA-10537] - Convert KStreamImpl filter to new PAPI
[KAFKA-10538] - Convert KStreamImpl map to new PAPI
[KAFKA-10541] - Convert KTable filter to new PAPI
[KAFKA-10587] - Rename kafka‑mirror‑maker CLI parameters for KIP‑629
[KAFKA-10588] - Rename kafka‑console‑consumer CLI parameters for KIP‑629
[KAFKA-10589] - Rename kafka‑replica‑verification CLI parameters for KIP‑629
[KAFKA-12158] - Consider improving return type of RaftClient.scheduleAppend
[KAFKA-12173] - Migrate streams:streams‑scala module to JUnit 5
[KAFKA-12267] - Implement DescribeTransactions API
[KAFKA-12368] - Non‑in‑memory implementation of RSM and RLMM
[KAFKA-12369] - Implement ListTransactions API
[KAFKA-12429] - Serdes for all message types in internal topics, default implementation in RLMM
[KAFKA-12434] - Admin API for DescribeProducers
[KAFKA-12441] - Delete deprecated StreamsBuilder#addGlobalStore
[KAFKA-12449] - Remove deprecated WindowStore#put
[KAFKA-12450] - Remove deprecated methods in ReadOnlyWindowStore
[KAFKA-12451] - Remove deprecated comments on long‑read operations in WindowStore
[KAFKA-12452] - Remove deprecated ProcessorContext#forward overload
[KAFKA-12467] - Implement QuorumController metadata snapshot
[KAFKA-12515] - ApiVersionManager should create response based on request version
[KAFKA-12536] - Add immediate‑method to ReadOnlySessionStore
[KAFKA-12552] - Extract segment map from Log class into separate class
[KAFKA-12553] - Refactor log layer recovery logic
[KAFKA-12568] - Delete deprecated "KStream#groupBy/join" and "Join#named" overloads
[KAFKA-12571] - Remove LeaderEpochFileCache constructor dependency on LogEndOffset
[KAFKA-12575] - Remove boolean property Log.isLogDirOffline
[KAFKA-12586] - Admin API for DescribeTransactions
[KAFKA-12596] - Delete deprecated --zookeeper from topicCommands
[KAFKA-12597] - Delete deprecated --zookeeper from ReassignPartitionsCommands
[KAFKA-12598] - Delete deprecated --zookeeper from ConfigCommand
[KAFKA-12630] - Delete deprecated KafkaClientSupplier#getAdminClient
[KAFKA-12631] - Support API to resign KRaft leader
[KAFKA-12633] - Delete deprecated "TopologyTestDriver#pipeInput / readOutput"
[KAFKA-12683] - Delete deprecated "UsePreviousTimeOnInvalidTimeStamp"
[KAFKA-12709] - Admin API for ListTransactions
[KAFKA-12716] - Admin API for terminating transactions
[KAFKA-12758] - Create new "server‑common" module and move ApiMessageAndVersion, RecordSerde, AbstractApiMessageSerde, BytesApiMessageSerde there
[KAFKA-12790] - Delete SslTransportLayerTest.testUnsupportedTlsVersion
[KAFKA-12796] - Delete deprecated classes under streams‑scala
[KAFKA-12808] - Delete deprecated methods in StreamsMetrics
[KAFKA-12809] - Delete deprecated methods in Stores
[KAFKA-12810] - Delete enabled TopologyDescription.Source#topics
[KAFKA-12813] - Delete deprecated scheduling methods in ProcessorContext
[KAFKA-12814] - Delete deprecated StreamsConfig#getConsumerConfig
[KAFKA-12816] - Add layered storage configuration
[KAFKA-12863] - Configure controller snapshot generation
[KAFKA-12884] - Delete "--zookeeper" from system tests
[KAFKA-12888] - Add transaction tool
[KAFKA-12905] - Replace EasyMock and PowerMock with Mockito for NamedCacheMetricsTest
[KAFKA-12924] - Replace EasyMock and PowerMock with Mockito in stream module (metrics)
[KAFKA-12929] - KIP‑750: Deprecate Java 8 support in Kafka 3.0
[KAFKA-12930] - KIP‑751: Deprecate Scala 2.12 support in Kafka 3.0
[KAFKA-12940] - Enable JDK 16 builds in Jenkins
[KAFKA-12944] - KIP‑724: Assume message format version 3.0 when IBP ≥ 3.0
[KAFKA-12952] - Metadata snapshot file separator
[KAFKA-12955] - Fix LogLoader to pass view of segments to be deleted
[KAFKA-12979] - Implement --find‑hanging API in transaction tool
[KAFKA-12992] - Expose kraft configuration properties
[KAFKA-13011] - Update deleteTopics Admin API
[KAFKA-13015] - Create system test for metadata snapshot
[KAFKA-13023] - Set "range, cooperative sticky" as default allocator in V3.0
[KAFKA-13059] - Update DeleteConsumerGroupOffsetsHandler
[KAFKA-13062] - Refactor DeleteConsumerGroupsHandler
[KAFKA-13063] - Refactor DescribeConsumerGroupsHandler
[KAFKA-13064] - Refactor ListConsumerGroupOffsetsHandler
[KAFKA-13072] - Refactor RemoveMembersFromConsumerGroupHandler
[KAFKA-13090] - Improve cluster snapshot integration test
[KAFKA-13113] - Add deregistration support to RaftClient
[KAFKA-13114] - Cancel listener registration when in‑memory snapshot is lost during abort
[KAFKA-13116] - KIP‑724: Adjust system tests due to KAFKA‑12944
[KAFKA-13165] - Validate node ID, process role and statutory voters