Confluent Platform Component Changelogs
This topic provides changelogs for the individual Confluent Platform components.
Version 8.2.0
Released March 2026
Community Features
Common
a9b992c5 - Update logredactor to 1.0.17 and netty to 4.1.130
3e0892c1 - Update log4j to 2.25.3
faa63c96 - Update dependency org.bitbucket.b_c:jose4j to v0.9.6 [SECURITY]
c33caa1b - Update Netty to 4.1.129
2a944f44 - Use correct groupname for commons-lang3
f9b8ce5a - Bump proto version
04dd96c1 - Upgrade to Avro 1.12.1
fdad7f91 - Add azure keyvault-keys dependency to management section to match ce-kafka
25ab4be8 - Fix the scope of imported pom
4eab14b4 - Update netty and bouncycastle
1b8bb0d3 - Add dependency management for grpc libraries and commons-lang3
68339fe3 - Update Jetty in common 8.0.1
c3793950 - Update Azure libraries
5efa5ead - Add httpclient5, remove zookeeper
c6784097 - Upgrade protobuf to 31.1 to match ce-kafka
fdbb7f8a - Udpate bc-fips versions to match ce-kafka / latest security updates in verified fips version
Kafka
PR-21471 - Share consumer group fails when group ID contains colon character
PR-21452 - Upgrade Jetty from 12.0.22 to 12.0.32
PR-21397 - Add documentation about the incompatibility of RocksDB file format
PR-21423 - Close pending tasks on shutdown.
PR-21385 - Handle pre-4.1 brokers in kafka-configs.sh for groups
PR-21396 - Group coordinator fails to unload metadata when no longer leader or follower
PR-20289 - Fix log dir going offline when log segment flush and file deletion overlap
PR-21335 - Made PartitionLeaderCache thread safe.
65faedb6 - Fix NPE in SSLUtils when ssl.cipher.suites not provided with listener-prefixed configs
PR-21362 - Do not set KAFKA_URL as ENV in Docker
PR-21319 - Add tests for duplicate heartbeat request handling
PR-21312 - Allow fenced members to rejoin streams group with epoch 0
PR-21309 - Allow fenced members to rejoin share group with epoch 0
PR-21305 - Allow fenced members to rejoin consumer group with epoch 0
PR-21170 - Documentation section on the streams rebalance protocol
PR-21318 - Fix wrong (uppercase) PluginType JSON serialization
PR-21300 - Remove templateData.js in release.py
PR-21296 - Fix Docker build hang by reordering tar extraction before…
PR-21285 - Fix rare producer message corruption, don’t reuse buffers
PR-21265 - Share commitSync for deleted topic
PR-21253 - Fix consumer position updates and unsubscribe when using committed offsets with topic ID
PR-21249 - Upgrade Log4j to 2.25.3
PR-21258 - Switched the java version for streams-scala from 17 to 11.
PR-21243 - Fix the broken quick start link
PR-21222 - Fix kafka-reassign-partitions.sh to handle dead brokers
PR-21176 - Transaction coordinator livelock caused by invalid producer epoch
PR-21167 - Reset-by-duration should not hand back task to state-updater
PR-21027 - Reduce the log4j2 cpu usage in PersisterStateManager
PR-21135 - Gracefully handle exceptions when handling AllocateProducerIdsResponse
PR-21159 - Remove 2PC public APIs from 4.2 until release (KIP-939)
PR-21155 - TaskManager may not close all tasks on task timeouts
PR-21130 - Add metrics from KIP-1216 to ops.html
PR-21129 - Document streams groups metrics changes in ops.html
PR-21120 - Update session and window store with new default when no open iterators
PR-21011 - Apply rebalance delay also for later epochs if the group is empty
PR-21110 - Don’t enter running state as long as group is not ready
PR-21031 - Always set status field in StreamsGroupHeartbeat response
PR-21091 - Refactor to reset timestamp to zero when no open iterators
PR-20907 - Group coordinator loading may fail when there is concurrent compaction
PR-21046 - Document queues metrics changes in ops.html
PR-21035 - Update lz4 dependency version
PR-21107 - Do not bump member epoch when exiting UNREVOKED_PARTITIONS
PR-21082 - Upgrade commons-validator to 1.10.1
PR-21092 - Bump delivery count on session release
PR-21081 - Increasing batch size to fix throttled delivery test
PR-21071 - Mark session stale when removed prior disconnection event
PR-21013 - Bump group epoch when member regex subscription transitions from non-empty to empty
PR-20931 - Fix the documentation for remove controller
PR-21064 - Accumulate offsets response in same batch
PR-21058 - Fix performance regression in server-side assignors
PR-21033 - Simplify skipping of empty ShareFetch requests
PR-21024 - Kafka-share-groups.sh describe offsets message improvement
PR-21051 - Fixing overlapping batches post re-initalization of Share Partition
PR-21050 - Bug releasing acquired records when maintained per offset
PR-20674 - Add nodeId to DescribeFeaturesOptions
PR-21016 - Add process handler null check for global threads
PR-21001 - Add retry and backoff mechanism in NetworkPartitionMetadataClient
PR-21007 - Fix polling delay for share consumer in record-limit mode
PR-20324 - Check for ability to skip position validation in application thread when collecting buffered data
PR-20998 - Add retry for network and req timeout resp errors.
PR-20946 - Update streams/developer-guide/app-reset-tool.html
PR-20986 - Clamp negative values in coordinator histograms
PR-20960 - Duplicated topic config prevents broker start
PR-20971 - Integration tests for share group throttled delivery
PR-20952 - Deprecate ‘–max-partition-memory-bytes’ option in ConsoleProducer
PR-20767 - Improved error handling in DefaultStateUpdater.
PR-20945 - Use eclipse-temurin as the base image to align with 3.9
PR-20837 - Improve handling of delivery count
PR-20909 - Integration tests for KIP-1226
PR-20889 - Some test replacements [7/N]
PR-20923 - Mark OffsetCommit and OffsetFetch APIs as stable
PR-20929 - Consider bumping 3rd party Github Actions
PR-20925 - KIP-932 documentation updates
PR-19886 - Fix termination issue in ConsoleConsumer and ConsoleShareConsumer
PR-20916 - Interface stability and deprecation
PR-20918 - Share consumer javadoc enhancements
PR-20930 - Close ConsumerNetworkThread on failed start
PR-20906 - Clean client level metric tags
PR-20882 - Propagate transaction version info to producer epoch check
PR-20914 - Fix to not update positions for partitions being revoked
PR-20922 - Use MockTime::sleep in ShareConsumeRequestManagerTest.
PR-20921 - Generator | Fix order of arguments to assertEquals in unit tests
PR-20915 - Reintroduce SaslPlainSslEndToEndAuthorizationTest
PR-20741 - Add documentation for Gradle version upgrade process
PR-19885 - Client support for OffsetFetch with topic ID
PR-20855 - Send Share-Fetch one-node at a time for record_limit mode
PR-20905 - Client use of ShareAcknowledge acquisition lock timeout
PR-20792 - Failure in ConsumerNetworkThread.initializeResources() can cause hangs on AsyncKafkaConsumer.close()
PR-20900 - 2/N Additional share consumers tests.
PR-20901 - Add acq lock timeout ms field to share ack response.
PR-20895 - Implement acquisitionLockTimeoutMs
PR-20852 - Create an implementation class NetworkPartitionMetadataClient for PartitionMetadataClient
PR-20626 - Regex subscription should be empty for classic members joining mixed group
PR-20781 - Don’t consider partitions unreleased when pending revocation by the current member
PR-20886 - Replace the base image since openjdk image is deprecated
PR-20780 - Implement coordinator adaptive batch linger time
PR-20403 - Set dummy ProcessorRecordContext for processor init
PR-20808 - Fix CoordinatorExecutorImpl.cancelAll implementation
PR-20754 - [2/2]: Add coordinator batch flush rate metric
PR-20880 - Handle exceptions in acknowledgement callback
PR-20753 - [1/2]: Add coordinator effective batch linger time metric
PR-20841 - Mark streams groups records and APIs stable
PR-20858 - More test replacements [6/N]
PR-20755 - Implement group-level initial rebalance delay
PR-20868 - Add Transaction Version to request builder [2/3]
PR-19459 - The refresh_collaborators.py script messes .asf.yaml
PR-20857 - Add transaction version field [1/3]
PR-20693 - Add logs for Kafka Streams task readiness
PR-20842 - Add latency optimization guidance to KafkaProducer.send()
PR-19577 - [1/N] Client support for OffsetCommit with topic ID
PR-20838 - [1/N] Renew acks in share consumer
PR-20152 - Incorrect rate metric with larger window size
PR-20839 - Compute share partition lag in GroupCoordinatorService
PR-20723 - Adding allow topic creation false for global and restore consumer
PR-20856 - [1/N] Mark KIP-932 as generally available
PR-20831 - Move partition state classes from storage to server module
PR-20840 - Add client id to share consumers in ShareConsumerPerformance
PR-20843 - Remove the futureless remove task as it’s no longer used.
PR-20829 - Handle TimeoutException from initializeIfNeeded() in StateUpdater Code
PR-20818 - More test replacements [5/N]
PR-20254 - Add test to verify data-loss bug was fixed inside the producer
PR-20819 - Remove uuid to string conversion and vice-versa for memberId on broker
PR-20760 - Add per-partition epoch validation to streams groups [4/N]
PR-20730 - Track assignment epochs in streams groups [3/N]
PR-20799 - Remove all unused static classes in Field
PR-20826 - ShareFetch related changes to support RENEW.
PR-20246 - [1/n]: Handle strict max fetch records in share fetch
PR-20823 - Start offset moved incorrectly on receiving acknowledgements for offset post LSO movement
PR-20359 - Optimization of the Murmur2 hash computation
PR-20815 - SharePartition RENEW ack impl.
PR-20672 - Include push interval in ClientTelemetryReceiver context (KIP-1217)
PR-20771 - Admin client changes for KIP-1226
PR-20820 - Add deliveryCompleteCount to ReadShareGroupStateSummary
PR-20617 - The records appended to the log are illegal because of an incorrect base offset during TestLinearWriteSpeed
PR-20521 - High CPU load when AsyncKafkaConsumer uses a small max poll value
PR-20810 - Add deliveryCompleteCount to writeState, ShareUpdate and ShareSnapshot schemas
PR-20794 - Add check to send one ShareFetchEvent per poll in ShareConsumer.
PR-20777 - More cleanup and rewrite [4/N]
PR-20809 - Fix a typo in README.md file
PR-20751 - Make RecordHeader reads thread-safe (KIP-1205)
PR-20203 - TopicBasedRemoteLogMetadataManager’s initial should happen after the broker ready (KIP-1197)
PR-20748 - Incorrect jitter value in StreamsGroupHeartbeatRequestManager and AbstractHeartbeatRequestManager
PR-20719 - Move KRaftClusterTest from core module to server module [1/N]
PR-20762 - Add RPC-level integration tests for StreamsGroupHeartbeat [2/2]
PR-20481 - Implement request handler metrics defined in KIP-1207
PR-20757 - Add RPC-level integration tests for StreamsGroupHeartbeat [1/2]
PR-20732 - Protocol and API changes for KIP-1222
PR-20787 - Introduce computations for inFlightTerminalRecords
PR-20724 - Add Idle Thread Ratio Metric to MetadataLoader
PR-20745 - Remove the unnecessary copy from AbstractFetch#fetchablePartitions
PR-20083 - Move and rewrite partition state classes to Java in org.apache.kafka.storage.internals.log
PR-20765 - Use ShareFetchUtils mock for DelayedShareFetchTest tests
PR-20752 - Log an error when we get duplicate acquired offsets in ShareFetchResponse.
PR-20750 - New AllowlistConnectorClientConfigOverridePolicy (KIP-1188)
PR-20746 - PartitionMaxBytesStrategy bug when request bytes is lesser than acquired topic partitions
PR-20766 - Add application tag to clientstate metric
PR-20318 - Optimize BeginQuorumEpoch heartbeat
PR-20691 - KIP-1227: Expose rack ID in MemberDescription and ShareMemberDescription
PR-20744 - Implemented support for allow.os.group.write.access config.
PR-19876 - Move DelayedRemoteFetch to the storage module
PR-20758 - Call ack commit callback at end of waiting calls
PR-20708 - Reset share group offsets for unsubscribed topics
PR-20737 - Add partitions to share fetch buffer together
PR-20703 - Gracefully stop test execution if .git does not exist
PR-20740 - Duplicated batches should be logged
PR-20735 - Fix consumption and leaving group when source topic is deleted
PR-20640 - Tools | Fix order of arguments to assertEquals in unit test
PR-20738 - Handle batch alignment when share partition is at capacity
PR-20675 - Preferably use the connector classloader when loading pl…
PR-20728 - KIP-1136 annotate constructors in ConsumerGroupMetadata @Deprecated
PR-20704 - Update SpotBugs version and enable Spotbugs Gradle tasks on Java 25
PR-20711 - Gradle build fails after Swagger patch version update
PR-20714 - Add partitions to offset commit validation [1/N]
PR-20573 - Streams package assertEquals arguments adjustments
PR-20546 - Add support for podman when running system tests
PR-20702 - Store the last used assignment configuration in the group metadata
PR-20717 - Introduce source topic to subtopology map [2/N]
PR-20668 - Global stream thread should not ignore any exceptions
PR-20285 - At_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
PR-20642 - Move DynamicClientQuotaPublisher to metadata module
PR-20653 - RecordTooLargeExceptions in group coordinator when offsets.topic.compression.codec is used
PR-20706 - Mark the minOneMessage as false when delayedRemoteFetch is present in the first partition.
PR-20665 - Don’t fail if nextOffsetsAndMetadataToBeConsumed is not available.
PR-20654 - Parallel remote reads cause memory leak in broker
PR-20464 - Add metrics corresponding to consumer rebalance listener metrics
PR-20293 - Improve Exit Code Handling in StreamsGroupCommand
PR-20600 - Streams groups sometimes describe as NOT_READY when STABLE
PR-20692 - Cleanup and rewrite more tests in TaskManagerTest [3/N]
PR-20673 - Replace –property with –reader-property in ConsoleProducer (KIP-1147)
PR-20689 - Enhance the documentation for Node#isFanced
PR-20676 - Fix log values for leader epoch
PR-20544 - Remove more dead tests and rewrote 3 tests in TaskManagerTest [2/N]
PR-20661 - Update ClientTelemetryReporter telemetry push error handling
PR-20671 - Fix log values for previous leader id and epoch
PR-20646 - Clear pendingTasksToInit on tasks clear.
PR-20399 - Remove the usage of KafkaMetricsGroup(Class<?> klass)
PR-20561 - Support building with Java 25 (LTS release)
PR-20632 - Add RPC-level integration test for StreamsGroupDescribeRequest
PR-19955 - Refactor Kafka Streams CloseOptions to Fluent API Style
PR-19513 - Gradle version upgrade 8 –>> 9
PR-20565 - Add consumer rebalance metrics test
PR-20637 - Move StateChangeLogger to server-common module
PR-20055 - Ensure consumer and share assignment consistency with subscriptions
PR-20543 - Move Gauge#value to MetricValueProvider
PR-20628 - Address the compileClasspath resolution warnings for the task
PR-20633 - Fix metrics leak in Kafka Streams
PR-20539 - Removed versions 2.3 and below from UpgradeFromValues.
PR-19400 - Remove internal.leave.group.on.close config
PR-20613 - Move restore time calculation to ChangelogMetadata
PR-20422 - Add a metric for controller thread idleness
PR-20618 - Add epoch check before verification guard check to prevent unexpected fatal error
PR-20536 - Kafka protocol BNF format should have some way to display tagged fields
PR-20606 - Update streams documentation with KIP-1147 changes
PR-20583 - [MINOR] Cleaning ignored streams test
PR-20604 - –no-initial-controllers should not assume kraft.version=1
PR-19961 - Call safeForceUnmap() in AbstractIndex.resize() on Linux to prevent stale mmap of index files
PR-19304 - Filter topics before sorting
PR-20234 - Kafka Streams should also purge internal topics based on user commit requests
PR-20540 - Strengthen AdjustStreamThreadCountTest with stateful counting and higher throughput
PR-19914 - AsyncConsumer#close hangs as commitAsync never completes when coordinator is missing
PR-20601 - Upgrade commons-validator to 1.10.0
PR-20526 - Move MetadataVersionConfigValidator and related test code to metadata module
PR-20265 - Rename AssignmentsManager and RemoteStorageThreadPool metrics
PR-20388 - ConsumerPerformance#ConsumerPerfRebListener get corrupted value when the number of partitions is increased
PR-20574 - StreamsGroupDescribe result is missing topology
PR-20591 - Clear out coordinator snapshots periodically while loading
PR-20581 - Rebalance should be triggered by subscription change during group protocol downgrade
PR-18339 - Explicitly set up instrumentation for inline mocking (Java 21+)
PR-20551 - –no-initial-controllers should not assume kraft.version=1
PR-20586 - Fix arguments to assertEquals() in clients module
PR-20248 - Improve MetadataVersion.fromVersionString() to take an enableUnstableFeature flag
PR-20417 - Rebalance should be triggered by subscription change during group protocol downgrade
PR-20044 - Java.awt.headless should not be on commandline
PR-20475 - Move DelegationTokenPublisher to metadata module
PR-20534 - Add epoch check before verification guard check to prevent unexpected fatal error
PR-20385 - Improve consistency of command-line arguments for consumer performance tests
PR-19927 - Stabilize RemoteIndexCacheTest
PR-17554 - Improvements to Dockerfile
PR-18322 - Remove top-level version field from docker-compose.yml files
PR-20493 - AppInfo metrics don’t contain the client-id
PR-20504 - Improve MetadataShell tool by skipping missing children and removing zkMigrationState
PR-20524 - Enhance the documentation for producer headers and integration tests
PR-20557 - Add missing metric assigned-partitions for new consumer
PR-20547 - Clear out coordinator snapshots periodically while loading
PR-20541 - Enable streams rebalance protocol in IQv2 integration test
PR-20527 - Improve the documentation of
RecordsToDeletePR-20479 - Implement KIP-1147 for console producer/consumer/share-consumer.
PR-1790 - Remove ksql from codeowners
PR-20501 - Remove dead tests and modify tests in TaskManagerTest [1/N]
PR-20511 - Trigger StreamsRebalanceListener in Consumer.close
PR-20409 - Document controller.quorum.auto.join.enable config in upgrade.html
PR-20523 - [6/N]: Use heaps also on the process-level
PR-20460 - Move TransactionLogTest to transaction-coordinator module
PR-19623 - Replace ApiError#exception by Error#exception for KafkaAdminClient
PR-20498 - Remove old restoration codepath from RestoreIntegrationTest [4/N]
PR-20519 - Fix bug in redundant offset calculation.
PR-20508 - EpochState should override close to avoid throwing IOException
PR-20516 - Fix bug in redundant offset calculation.
PR-20458 - [5/N]: Use below-quota as a condition for standby task assignment
PR-20499 - Remove old restoration codepath from EosIntegrationTest [5/N]
PR-20468 - Move ScramPublisher to metadata module
PR-20178 - Remove usages of distutils in docker scripts
PR-20512 - Fix NoSuchElementException in oldest open iterator metric
PR-20507 - Added PersisterBatch record in Share Partition which includes updatedState and stateBatch
PR-20486 - [4/N]: Prefer range-style assignment
PR-20266 - Integration test for Streams-related Admin APIs [2/N]
PR-17930 - AddRaftVoter responds with error message “NONE” instead of null
PR-20491 - Avoid noisy NPE logs when closing consumer after constructor failures
PR-20465 - Remove old restoration codepath from SmokeTestDriverIntegrationTest [3/N]
PR-20483 - JoinWithIncompleteMetadataIntegrationTest fails in isolated run of one parameter
PR-20463 - Remove old restoration codepath from PauseResumeIntegrationTest [2/N]
PR-20482 - Kafka-acls should return authorization already done if repeating work is issued
PR-20470 - ProcessValue() must be declared as value-changing operation
PR-20334 - Unifying LIST-Type Configuration Validation and Default Values
PR-20490 - Wrong generic type for UnregisterBrokerOptions
PR-19980 - Async consumer fetch intermittent delays on console consumer
PR-20451 - Tweak org.apache.kafka.clients.consumer.OffsetAndMetadata
PR-20462 - Clean up integration tests related to state-updater
PR-20453 - Allow resetting offset for unsubscribed topic in kafka-share-groups.sh
PR-20467 - Close ShareConsumer in ShareConsumerPerformance after metrics displayed
PR-20244 - Integration test for Streams-related Admin APIs [1/N]
PR-20046 - Add an ERROR log message if broker.heartbeat.interval.ms is too large
PR-20420 - Add integration tests for DescribeProducersOptions#brokerId
PR-20301 - Improve EndToEndLatency Tool with argument parser and message key/header support
PR-20172 - [3/N]: Use heaps to discover the least loaded process
PR-20438 - Improve metavariable names in usage messages
PR-20283 - Refactor AsyncConsumerMetrics to not extend KafkaConsumerMetrics
PR-20267 - Close Consumer in ConsumerPerformance only after metrics displayed
PR-20302 - Improve producer and consumer config files
PR-20414 - Add a lower bound to num.replica.fetchers
PR-20396 - Add compression type and level support to LogCompactionTester
PR-20431 - KIP-1147 Consistency of command-line arguments for remaining CLI tools
PR-20358 - Fix stack overflow when batch size is larger than cluster max.message.byte
PR-20415 - KIP-1147 changes for upgrade.html
PR-20412 - Implement integration test for offline migration
PR-20242 - Topic replay code does not handle creation and deletion in the same delta
PR-20236 - Add an end-to-end integration test for the DLQ feature
PR-20390 - Consistency of command-line arguments for verifiable producer/consumer
PR-20405 - Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs
PR-16584 - Add EarliestPendingUpload offset spec in ListOffsets API
PR-20249 - Add documentation to remind users to use valid LogLevelConfig constants
PR-18644 - Cleanup NetworkClient zk related logging
PR-20395 - Handle overlap batch on partition re-assignment
PR-16884 - Add empty replica FollowerFetch tests
PR-20288 - Implement offline migration for streams groups
PR-19028 - Enable to test docker image locally
PR-20070 - Deflake streams_smoke_test, again
PR-20221 - Add include argument to ConsumerPerformance tool
PR-20144 - Implement dynamic compression type selection and fallback for client telemetry
PR-20319 - The current assignments shown by ReassignPartitionsCommand should include the log directories
PR-20361 - Command-line arguments for producer perf test
PR-20346 - Cleanup Metadata Module
PR-20391 - Reordered OR operands in archiveRecords method for SharePartiton
PR-20379 - The
record-sizeandthroughputarguments don’t work in TestRaftServerPR-20345 - Reduce the frequency of ReplicaNotAvailableException thrown to clients when RLMM is not ready
PR-20342 - Stop the RSM after closing the remote-log reader threads to handle requests gracefully
PR-19905 - Migrate LogCompactionTester to tools module
PR-20335 - Replace PartitionState with PartitionRegistration in makeFollower/makeLeader
PR-20338 - The passing of BrokerRegistrationRequestTest is a false positive
PR-19699 - Move TransactionMetadata to transaction-coordinator module
PR-20354 - Fix the busy loop occurring in kraft client observers
PR-20339 - Move AdminClientWithPoliciesIntegrationTest to clients-integration-tests module
PR-20340 - Improve visibility when topic auto-creation fails
PR-19589 - Automatic controller addition to cluster metadata partition
PR-20336 - TestGenerateAssignmentWithBootstrapServer uses wrong JSON format
PR-20333 - Upgrade to spotbugs 4.9.4
PR-20280 - Added the check for underlying partition being the leader in delayedShareFetch tryComplete method
PR-20290 - Added check to prevent NPE logs during ShareConsumer::close
PR-20322 - Document deprecation of PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG
PR-20310 - Correcting max delivery on write state failure and lock timeout
PR-20316 - Move persister call outside of the lock (3/N)
PR-20315 - Remove unnecessary update for find next fetch offset
PR-20317 - Fix the typo
PARTITIONER_ADPATIVE_PARTITIONING_ENABLEin ProducerConfigPR-20299 - Update num.recovery.threads.per.data.dir configs
PR-1746 - Change ci_tools import path
PR-1756 - Add run_tags to worker-ami and aws-packer
8c6a0550 - Tagging
f81747e2 - Add cflt_managed_by and cflt_managed_id to aws-packer.json
de16dd10 - Temporary fix for Streams system tests
PR-19449 - Support external schemas in JSONConverter
PR-20304 - Add missing metrics for doc tiered storage
PR-20269 - Fix typo in state-change log filename after rotate
PR-20264 - Update jfreechart dependency
PR-18526 - SASL session expiration time will be overflowed when calculation
PR-20286 - Concurrent execution fixes for lock timeout and lso movement
PR-20274 - State updater sensor names should be unique
PR-20247 - (II) : Complete any pending acknowledgements in ShareFetch on an error response.
PR-20258 - Set OP_WRITE interest after SASL reauthentication to resume pending writes
PR-20222 - Fix UnsupportedOperationException in connect-plugin-path
PR-20262 - State updater sensor names should be unique
PR-20261 - Improve the add controller doc
PR-20136 - Extra validation when formatting a node
PR-20218 - RemoteLogManager should record lag stats when remote storage is offline
PR-20129 - Fix bug with tiered storage throttle metrics
PR-19820 - [3/N]: Add AdminClient.alterShareGroupOffsets
PR-20255 - Remove ShareFetchMetricsManager sensors on consumer.close()
PR-20253 - Restrict records acquisition post max in-flight limit
PR-19517 - Fix mismatched StreamThread ID in log messages
PR-20192 - Deprecate BrokerNotFoundException
PR-19854 - KRaft observer should send fetch to best node
PR-20245 - Remove the handling of FatalExitError in RemoteStorageThreadPool
PR-20007 - Stop the server when fail to initialize to avoid local segment never got deleted.
PR-20148 - Enable acknowledgement for a record which could not be deserialized
PR-19982 - Update AddRaftVoterRequest RPC to version 1
PR-20233 - Remove MetadataVersionValidator
PR-20175 - Correct the logger name in PersisterStateManagerHandler
PR-17340 - Enable warmup in producer performance test (KIP-1052)
PR-20230 - Move inflight batch and state classes from SharePartition (2/N)
PR-20227 - Move acquisition lock classes from share partition (1/N)
PR-20201 - Gracefully handle error while building remoteLogAuxState
PR-1708 - In case of infra failure in ccs-kafka tag that as infra failure in testbreak
PR-20204 - Refactor TopicBasedRLMM implementation to remove unused code
PR-20039 - Add initPid Response handling when keepPrepared is set to true (KIP-939)
PR-20134 - Client ignores default properties
PR-20165 - Update OpenJDK base image from buster to bullseye
PR-20208 - Deprecate MX4j support
PR-18293 - Improve jmh tests on ACL in AuthorizerBenchmark and StandardAuthorizerUpdateBenchmark
PR-17942 - Add dead letter queue in Kafka Streams
PR-20207 - Remove AtomicBoolean for findNextFetchOfffset (1/N)
PR-20168 - kafka-consumer-groups.sh should fail quickly if the partition leader is unavailable
PR-20103 - Add share group admin integration tests to PlaintextAdminIntegrationTest
PR-20206 - Include control records in LoadSummary#numRecords
PR-20200 - Avoid electing fenced lastKnownLeader
PR-20196 - Bump Commons-Lang
PR-20185 - Improve error message when release version is wrong
PR-20061 - Encapsulate MetadataImage in GroupCoordinator/ShareCoordinator
PR-20173 - Add missing MVs in MetadataVersionTest
PR-20082 - Resume cleaning on future replica dir change
PR-20084 - Update /streams/developer-guide/security.html for KIP-1071
PR-20167 - Allow mocking UnifiedLog#topicId in ReplicaManagerTest
PR-20040 - Allow the coordinator to grow its buffer dynamically
PR-19847 - Make ClientQuotaImage and TopicImage immutable
PR-20157 - List internal topics for the user
PR-20166 - Remove unused metrics reporter initialization in KafkaAdminClient
PR-20021 - Add generic feature level metrics
PR-20064 - Optimize kafka-consumer-groups.sh to return the offset info when some partitions without leaders
PR-20045 - Allow reading from remote storage for multiple partitions in one fetchRequest
PR-20127 - [2/N]: Remove task pairs
PR-20111 - Improve documentation of fetch.min.bytes and replica.fetch.min.bytes
PR-20154 - Deflake streams admin api describe test
PR-20151 - Update config for native image (v4.1.0)
PR-20150 - Update native image config for native images
PR-20135 - Added check before sending acknowledgements on initial epoch.
PR-20110 - LogConcurrencyTest should close the log when the test completes
PR-20118 - Sticky Assignor JMH Benchmark
PR-1684 - Migrate from vagrant to terraform
PR-20071 - Add documentation for upgrading the kraft version
PR-19209 - Remove argument force_use_zk_connection from kafka_acls_cmd_with_optional_security_settings
PR-20104 - Make share group init retry interval configurable.
PR-20126 - ShareConsumerPerformance does not handle exceptions from consumeMessagesForSingleShareConsumer
PR-20106 - Move WARN log on log truncation below HWM
PR-19664 - Created GetReplicaLogInfo RPCs
PR-20099 - Fix Streams CLI describe
PR-20120 - [1/N]: Precompute values in ProcessState
PR-20116 - Add back JoinGroup v0 & v1
PR-20081 - Move PlaintextConsumerTest to client-integration-tests module
PR-19964 - Ensure consistent metadata usage in produce request and response
PR-19971 - Move ProducerSendWhileDeletionTest to client-integration-tests module
PR-19807 - Move ControllerMutationQuotaManager to server module
PR-20101 - Ignore unsubscribed topics when computing share assignment
PR-20074 - Finalize heterogeneous simple share assignor
PR-20100 - Ignore group not found in share group record replay
PR-20090 - Handle topics missing in metadata in share delete.
PR-20049 - Handle top-level errors in AlterShareGroupOffsets RPC
PR-20088 - Count fetch size when remote fetch
PR-20080 - NextFetchOffset does not take ongoing state transition into account
PR-20076 - Ignore group not found in share group record replay.
PR-19899 - Don’t create the __remote_log_metadata topic when it already exists during broker restarts
PR-20079 - State and leader epoch should not be updated on writes.
PR-20078 - Retry persister request on metadata image issues.
PR-20025 - Add top-level documentation for OAuth flows
PR-20029 - Basic upgrade guide for KIP-1071 EA
PR-20062 - Fix coordinator runtime metrics sharing sensors
PR-20037 - Remove ReplicaManager#becomeLeaderOrFollower
PR-19822 - Rewrite ConsumerBounceTest by Java
PR-19988 - Add new Kafka Streams exception classes
PR-20002 - Don’t export SocketServer from ClusterInstance
PR-20041 - Restrict cache update for ongoing batch/offset state
PR-19704 - OffsetFetch API does not return group level errors correctly with version 1
PR-19920 - Fix LoggingResourceTest#testSetLevelDefaultScope
PR-19742 - Update quotaTypesEnabled on quota removal in ClientQuotaManager
PR-19985 - Remove 2PC public APIs from 4.1 until release (KIP-939)
PR-1672 - Exclude newly added files to fix build
PR-20014 - Migrate tests to use applyDelta instead of becomeLeaderOrFollower for testInconsistentIdReturnsError and others
PR-1663 - Add cloudwatch metrics to view cpu, memory and disk usage
PR-20022 - (De)Register oldest-iterator-open-since-ms metric dynamically
PR-20033 - Handle the deleted topics when applying ClearElrRecord
PR-19745 - Fix BrokerLifecycleManager RPC timeouts
PR-19974 - Fix deleteAcls bug which allows more deletions than max records per user op
PR-19916 - Handle the deleted topics when applying ClearElrRecord
PR-19157 - Fix the inconsistent lastest supported version in StorageTool.scala and FutureCommand
PR-19972 - Fix potential IllegalStateException when appending to timeIndex
PR-20019 - Deflake streams_smoke_test
PR-19999 - Deflake streams_broker_down_resilience_test
PR-20004 - Deflake streams_application_upgrade_test
PR-20009 - Remove becomeLeaderOrFollower from testPartition*, testPreferredReplicaAs*
PR-19884 - Make org.apache.kafka.common.test.TestUtils package-private to prevent cross-module access
PR-19987 - KafkaPrincipalBuilder should extend KafkaPrincipalSerde
PR-19951 - Typo in EventAccumulator.java
PR-20005 - Deflake streams_broker_bounce_test
PR-19977 - Finalize homogeneous simple share assignor
PR-19646 - Add support for kafka-streams-groups.sh options (reset-offsets) [1/N]
PR-19476 - ConnectAssignor#performAssignment parameter can be replace to ConnectProtocolCompatibility
PR-19753 - Update-cache.sh use curl + jq to get sha contains gradle cache instead of gh cli
PR-19776 - Rewrite IntegrationTestUtils by java
PR-19992 - Reduce running time of ShareConsumerTest
PR-19962 - Remove BrokerTopicStats#removeOldFollowerMetrics
PR-19983 - Prevent new consumer fetch assigned partitions not in explicit subscription
PR-18683 - Deprecated “org.apache.kafka.disallowed.login.modules”
PR-19917 - Refactor AsyncKafkaConsumer’s use of Java Streams APIs in critical sections
PR-19981 - Extended AuthorizerIntegrationTest to cover StreamsGroupDescribe
PR-19978 - Extended AuthorizerIntegrationTest to cover StreamsGroupHeartbeat
PR-19976 - Follow up bug fix
PR-19800 - Faster KRaft HWM replication
PR-19857 - Don’t propagate the error caused by CreateTopicPolicy to FatalFaultHandler
PR-19933 - [2/N] Move AddPartitionsToTxnManager files to java
PR-19966 - Remove ReplicaManager#becomeLeaderOrFollower from testFencedErrorCausedByBecomeLeader and other similar methods
PR-19965 - Migrate ReplicaManagerTest#testTransactionAddPartitionRetry and other similar methods to use applyDelta
PR-19954 - Migrate ReplicaManagerTest to use applyDelta
PR-19960 - Migrate ReplicaManagerTest RemoteFetchExpiresPerSecMetric and RemoteLogReaderMetrics with applyDelta
PR-19952 - Migrate ReplicaManagerTest#testOffsetOutOfRangeExceptionWhenFetchMessages to use applyDelta
PR-19880 - Upgrade RocksDB dependency from 9.7.3 to 10.1.3
PR-1655 - Add back deprecated constructors in KafkaBasedLog
PR-19809 - Add dynamic config remote.log.manager.follower.thread.pool.size
PR-19938 - Add OAuth integration tests
PR-19910 - Fix InitProducerId with TV2 double-increments epoch if ongoing transaction is aborted
PR-19814 - Use assigned topic IDs to avoid full metadata requests on broker-side regex
PR-19946 - Incorrect JWT parsing in OAuthBearerUnsecuredJws
PR-19904 - Time-based refresh for server-side RE2J regex
PR-19947 - Migrate testPartitionMetadataFile to use applyDelta in place of deprecated becomeLeaderOrFollower
PR-19924 - Update testClearPurgatoryOnBecomingFollower etc with KRaft mechanism in ReplicaManagerTest
PR-19923 - Remove ReplicaManager#becomeLeaderOrFollower in
testVerificationErrorConversionsPR-19939 - Force bump commons-beanutils
b311ac7d - Temporarily disable artifact publishing for the 4.1 branch.
PR-19607 - Propagate IOException on LogSegment#close
PR-19928 - Fix memory consumption for completed share fetch requests
ksqlDB
PR-10925 - Fix error in fips mode
PR-10917 - Fix fips error on startup
PR-10913 - Enable fips dynamically in shell script
PR-10912 - Update pom for fips compliance
PR-10905 - Print deprecated configs in maven builds.
PR-10908 - Fix checkstyle errors.
PR-10907 - Fix compilation errors.
PR-10906 - Fix compilation error for Fips validator.
PR-10903 - Update dependency io.vertx:vertx-web to v4.5.22
PR-10896 - Auto-migrate exactly_once to exactly_once_v2
PR-10897 - Explicitly set STATE_UPDATER_ENABLED to true
PR-10361 - Classify MissingSchemaException and RecordTooLargeException as user errors.
PR-10893 - Exclude kafka.brokerTypeTopicClient from thread pool check.
PR-10884 - Rely on common for httpclient5
PR-10869 - Upgrade jline dependency to address terminal sizing issue
94c228a6 - Bump up tcnative dependency.
PR-10865 - Bump up tcnative dependency to be in sync with netty.
PR-10854 - Update netty to 4.1.125
PR-10833 - Set the order of timestamp fields to be processed to avoid incorrect modifications for daylight savings.
707d2c90 - Update catch block to handle Throwable instead of Exception
PR-10845 - Unpin jackson version
PR-10841 - Unpin jackson version and upgrade shade plugin
PR-10808 - Added check for a compliant resource extension class name
PR-10831 - Fix ProcessValue and update historical plans
a3f4c676 - Update netty version
c75d9915 - Exclude >cc-custom-dns for packaging fix
REST Proxy
13fb1696 - Use .valid for listConsumerGroups() and fix some checkstyle issues
33f89369 - Fix partial permission issue for getConsumerGroups()
1df57555 - Bump Jersey dep to 2.46
26da27f0 - Dependcy update: bump jersey-apache-connector to 3.1.11
c492f6ac - Extend sem to 2 hours
PR-1420 - Fix spotbug check issue
897f4e61 - Increase to 2h
PR-1415 - Remove spotbug-annotations
PR-650 - Update jersey.version to 2.46
c5e11ac7 - Bump jersey.version from 3.1.9 to 3.1.11
89e30a3d - Remove unrelated HTTP/2 case for unencoded backslash
6fa7e6e2 - Remove HTTP/2 case for 400 error
61dc3772 - Fix Spiffe Dependency
92e909a4 - Allow suspicious URI characters 8.1.x
37f1efd1 - Master merge for suspicious character fix
a1096103 - Fix typo
fc9dae2d - Add tests
bd24ec6d - Feature flag for URI Compliance
7c66698b - Allow suspicious character
2d5ff9dd - Use LEGACY const
e3d90d38 - URL_ENCODED_BACKSLASH_PATH
65aa86ec - Legacy compatibility
975a760c - Allow backslash
PR-627 - Cherry-pick inc3209 changes from master
7e7af928 - Add missing import
389345d6 - Add tag param to thread-pool-usage
77b87c3d - Fix order
db84d15b - Update spiffe
PR-618 - Return the method metrics when requestTags are empty, instead of creating new MethodMetrics
PR-584 - Add ProxyCustomizer for accessing tlvs
PR-612 - Update java-spiffe version to 0.8.13
PR-611 - Add ProxyCustomizer for accessing tlvs
c4281451 - Make getSniServerName public
032e7c03 - Format
c08737d2 - Add debug logs to identify which method was called
89a5c8d5 - Reversed order of extraction to prioritize V4 networking method
PR-608 - [Spire] Remove explicit grpc-netty-linux
79d41879 - Change log from info to debug for volume reasons
c6b1332a - Remove redundant log
b60591b5 - Rename config for consistency
77e545c9 - Add rate limit violation detection to dry run mode
fd51de29 - Add unknown tenant log
5f8acdfe - Fix comments + always log
32490073 - Add dry run functionality
PR-600 - Temp: Add a feature flag to disable response size metrics collection
8ac145a6 - Uncomment tag
ac85f9d0 - Make tenant dos filter type IP to enable automatic cleanup for rate trackers
08fde42c - Default emptyMap() for capturedRequestTags
61c89204 - Co-pilot advice to catch exceptions better
0627cbb9 - Move comment to top
927b22c1 - Improve debug logs
b5f3039c - Removing checkstyle suppressions
cd5c4246 - Refactor to catch all NPEs and throw error log together
153ab833 - Request tags on request filter complete
06f2bc7c - Clean tests
5831b1b4 - Update comment
37746d2a - Remove redundant check
c3021c01 - Enable tenant rl in int test
ca5f3d7d - Remove test log lines
f0a87f45 - Remove references to v3 vs. v4 extraction
fd013393 - Rename methods for clarity
25a0b652 - Add comprehensive v4 pattern tests
204c6aa7 - Change fallback behavior to IP-based rate limiting rather than grouping unknown tenants
0cb6e861 - Fix: Check for NPEs before accessing request or response related objects
8f5ed16f - Make string parse more flexible
211fad6e - Add identifying comment to log
7d7b9aba - Add constant for unknown tenant
d23c05a0 - Simplify string parsing
f87727b8 - Replace regex with string matching for better performance
d2a2dd02 - Make default tenant rate limit 10
5efbc098 - Add more descriptive logs + update test
d171bec1 - Update log
6a963ef0 - Add unit test for tenant id parsing
fde964c2 - Added temporary logs for debugging
edea0b9a - Added int test for tenant rl
11bd68b4 - Enable tenant ratelimit by default
277e06b0 - Added tenant ratelimit
c7bc797e - Update minor+patch dependencies
Schema Registry
PR-4163 - Ensure guid is preserved when formatting schema responses
9a908000 - Add API to test shared KEKs to DEK Registry client
bb653688 - Ensure output schema is cached if it is returned
PR-4106 - Add checked exceptions for abstract MetadataEncoderService methods
5e81d37d - Refactor assoc response creation
2c7c1cae - First cut at batch API improvements
6cec9889 - Add validateNewSchemas config
d84bf175 - Fix MetadataEncoderService initialization bug
PR-4096 - Add SchemaValueHolder interface for type-safe schema value access
8be9ad56 - Add enableOnlyAt property to RuleSet
d587dc75 - Change AssociatedNameStrategy fallback to enum
PR-4093 - Make MetadataEncoderService backend-agnostic
PR-4091 - Fix MetadataEncoderService secret rotation and add test coverage
PR-4089 - Fix MetadataEncoderService key rotation and add test coverage
c77034d4 - Fix length calculation
d99b4812 - Reduce allocations in AbstractKafkaProtobufDeserializer
PR-4087 - Remove MetadataEncoderService’s tight coupling to KCache
ee7d984f - Fix Avro union evolution for specific reader
PR-4082 - Add dependency management entry for log4j version
PR-4077 - Exclude common-lang-2
aeda9ff5 - Add config to enable asssociation functionality
PR-4076 - Bump log4j to 2.25.3
PR-4072 - Upgrade CI instance, add retries
f7b701aa - Fix checkstyle
ee284c9c - Fix ContextFilter to handle associations path w/resource
3ea3f1b4 - Clean
c3506a86 - Change PUT associations endpoint to pass resource ID
13cd3fc7 - Add more tests for DEK rewrap functionality
c6beadf0 - Add back BoundedConcurrentHashMap but mark as deprecated
PR-4046 - Add tool to rewrap DEKs with latest version of KEK
PR-4043 - Add integration test tag to integration test classes
PR-4032 - Add support for Associations
PR-4042 - Allow encrypting a union of primitives
PR-4041 - Extract Context prefix logic in delete mode to a method
PR-4040 - Refactor remaining RestApi tests to be harness-agnostic
PR-4039 - Add Avro deser config “avro.fail.on.trailing.data”
1136f023 - Remove os
PR-4038 - Allow use.message.indexes to be set on ConfigSchemaIdDeserializer
47ba07d4 - Update
PR-4031 - Fixed some typos and added more checks in mock client test
PR-4033 - Don’t throw exception for JSON schema with format=serialized
PR-4030 - Handle subject with name “contexts” or “subjects”
PR-4029 - Update associations mock client 3
PR-4011 - Refactor integration test to be harness-agnostic
PR-4028 - More association changes for client APIs
PR-4022 - Configure customer handlers after security handler
PR-4019 - Handle raw http in JSON Schema drafts
PR-4015 - Add fips mode to SR config to support fips 140-3
PR-4012 - Handle multi-tenant default context in isContext()
43eba3f2 - Fix assert for Junit version
PR-4003 - Add support for contextPrefix on list contexts API
PR-4008 - Remove unnecessary comment in test harnesses
PR-4007 - Refactor ClusterTestHarness to extend generic SR test harness
e5703b49 - Fix assert of 7.9.x Junit
PR-4001 - Add support for recursive mode delete
PR-4004 - Allow function to be passed during Avro deserialization
PR-3997 - Expose deserialize APIs to return schema with value
PR-3998 - Optimization: replace BoundedConcurrentHashMap with guava cache
e1869a02 - Fix assert for junit version
PR-3968 - Add support for DELETE /mode
PR-3994 - Add Confluent-Accept-Unknown-Properties header to SR client
PR-3988 - Set RestConfig.JETTY_LEGACY_URI_COMPLIANCE
PR-3986 - Add exclusions for cc-custom-dns-resolver-java18 in Kafka dependency
PR-3985 - Remove addtional delta parameter from unit test
PR-3983 - Add exclusions for cc-custom-dns-resolver-java18 in Kafka dependency
PR-3984 - Fix unit test due to rest-util
PR-3981 - Fix use of JSON Schema serializer for key
PR-3979 - Add stubs for createAssociation(s) APIs
PR-3977 - Minor optimization to remove synchronized block
PR-3976 - Add payload encryption test for bytes payload
PR-3973 - Ensure lazy initialization is thread-safe
PR-3972 - Only use AWS role if the web identity token file is not set
cf58140d - Handling trailing hash in JSON Schema drafts
PR-3969 - Add Accept-Version to recognized headers
PR-3967 - Upgrade to Avro 1.12.1 part 2
PR-3965 - Associations client only create or update
PR-3964 - Add Accept-Version header to the SR client
617ea319 - Add association client entities
PR-3953 - Upgrade to Avro 1.12.1
PR-3955 - Ensure canonicalString() method is thread-safe
PR-3952 - Add guid setter
PR-3950 - In AvroConverter use name-based getter/setter only for valid names
PR-3946 - Replace add() with put() in getHeaders to overwrite them
PR-3943 - Log usage of MetadataEncoderService
PR-3790 - Always add X-Forward header to request forwarded to leader
f122adbe - Fix junit version calls
952373da - Set whitelistHeaders to true
PR-3939 - Cherry-pick change missed when resolving merge conflicts
PR-3928 - Refactor SchemaRegistry references to use the SchemaRegistry interface
PR-3936 - Remove sensitive schema data from thrown exceptions
PR-3935 - Ensure payloads are not unnecessarily redacted in DLQ
PR-3934 - Fix SchemaRegistryCoordinator based on upstream Kafka changes
PR-3933 - Init function should throw exception on failure
PR-3930 - Add a lenient policy for JSON Schema compat checks
PR-3914 - Add StoreUpdateHandler.init() function to call during KafkaStore initialization
PR-3924 - Add AppRole auth for HC Vault
PR-3923 - Add getRuleSetHandler method to SchemaRegistry interface
PR-3921 - Add additional methods to SchemaRegistry interface
PR-3917 - Add health check and SSL factory methods to SchemaRegistry interface
PR-3913 - Correct default and update example
f04f8359 - Remove unused Kafka imports from SchemaRegistryConfigTest
PR-3912 - Refactor schema registry references from KafkaSchemaRegist
PR-3903 - Add compatibility check script
PR-3897 - Add latest Protobuf descriptor.proto versions to tests
PR-3908 - Support custom configs in CompositeDeserializer
PR-3909 - Upgrade kcache to 5.2.3
PR-3907 - Avoid extra copying in protobuf serializer
PR-3900 - Avoid extra copying in protobuf serializer
PR-3904 - Ensure isKey is set for Avro/JSON key serializers
PR-3901 - Add golden file to test for MD5 regression
PR-3899 - New sr endpoint client addition
PR-3902 - Follow up PR to handle old CP versions
PR-3896 - Update RestService warn log to include error class name
PR-3889 - Change apache client request body to raw bits
PR-3894 - Remove protobuf.version in order to rely on the one from common
PR-3891 - Remove protobuf.version in order to rely on the one from common
PR-3890 - Ensure tags are used during schema evolution
PR-3884 - DeleteSubject message handler should only delete non-deleted versions
PR-3843 - Feat(avro-serializer): Allow providing a custom DatumWriter in AbstractKafkaAvroSerializer
PR-3805 - Configure customer handlers after security handler