Confluent Platform Component Changelogs
This topic provides changelogs for the individual Confluent Platform components.
Version 8.2.2
Released June 2026
Community Features
Common
a0045ed4 - Set protobuf.version to 4.32.1
c900cbb1 - Fold in newwave removal change
cb591d40 - Re-add jackson-annotations-version to avoid downstream build failures
2190cbb6 - [BOM] Bump confluent-common-bom to 0.1.1 (8.0.x)
3bc902d4 - [BOM] Use confluent-common-bom 0.1.0 for 9 deps (8.0.x)
2636f6a9 - Add jetty-alpn-*-client artifacts to dependencyManagement
bd2bfe51 - Update mina-core to 2.2.7
902d6f6b - Pin plexus-utils dependency to match ce-kafka
e0509516 - Update logredactor
c8e702a3 - Update type of BOM import to pom
e7ad2c1b - Fix the scope of jetty-bom import
2e1c456b - Re-add Jetty BOM in 8.0.x and later
396d1b59 - Update Jetty to 12.0.35
9c4d0eb1 - Update Jetty to 9.4.61
c35f82c6 - Re-scope spotbugs-annotations
ffeef69a - Remove Jackson-annotations definition as it was removed from rest-utils
c92168f8 - Update Netty to 4.1.133
52597d6c - Add Jackson annotations sub-version
37f6c330 - Update Jackson to 2.21.2
68160aa0 - Update Jackson to 2.18.6
feef7ef9 - Update bouncycastle to 1.84
98512fbb - Bump bouncycastle.jdk18 to 1.84 [security]
a3b037e1 - Bump snappy-java to 1.1.10.8
08b569e9 - Bump protobuf to 4.34.0
8d518a82 - Bump easymock to 5.6.0
8ebc0f2e - Bump jacoco-maven-plugin from 0.8.7 to 0.8.13 to align with other branches
d385ac2a - Remove easymock bump
d9a3403d - [BOM]: Bump commons-io, commons-compress, easymock, spotbugs on 8.2.x
9c2d2eaa - Replace jetty-bom with individual dependency definitions
93f81673 - Add log4j2 version definition and update version in log4j2-extensions
183addd9 - [BOM] Bump commons-io, commons-compress, spotbugs on 8.0.x
709f5e13 - [BOM] Bump commons-validator, junit-bom, bouncycastle FIPS on 8.0.x
f99909b2 - Update log4j2 to 2.25.4
e4108bcb - Use default buildx builder to fix chained cross-platform builds
f6f72532 - Update Netty to 4.1.132
c05abece - Update Jetty to 12.0.34
9cb23e8d - [BOM] Bump classgraph, easymock, snappy-java on 8.0.x
PR-927 - Rename docker-arm profile to docker-fabric8 and migration changes
88413aa1 - Update Jetty to 9.4.60 and ZooKeeper to 3.8.6
6abdbc48 - Fix regex
2bc43e24 - Update version string
0f55ed5b - Update Avro to 1.11.5 in 7.9.6
952e3d32 - Update Avro to 1.11.5 in 7.8.7
e8cf967f - Update Avro to 1.11.5 in 7.7.8
62db0fed - Update Avro to 1.11.5 in 7.6.10
71f054dd - Update Avro to 1.11.5 in 7.5.13
217dac01 - Update Avro to 1.11.5 in 7.4.14
d5a703f7 - Update Avro to latest patch release
941fddcb - Backport pr_ci_gating and status_level from master to service.yml
PR-902 - Add –direct-pom-edit support to ci.py for faster CI builds
745599ac - Update Jetty to 9.4.59
9559effb - Add logback-core dependency management to resolve bazel <–> maven conflicts
Kafka
PR-22362 - Upgrade gradle action to enable the CI
PR-22269 - Fix handling of listener-prefixed SSL configs
PR-22216 - Backwards compatible advertised.listeners when it is not defined
7514c0b2 - Delete dynamic configs that were removed by Kafka
PR-22152 - Fix empty heading - Adding upgrade instructions for 4.1 - in 4.2 branch
PR-22130 - Moving future completion out of locks for Share Partition
PR-22117 - Upgrade log4j2 to 2.25.4
PR-21911 - Bump maven artifact to 3.9.15
PR-21983 - Fix stickyNode using stale IP when broker address changes
PR-21997 - Handle wakeup on poll reconciliation check
PR-21897 - Fix to ensure app thread not collecting records for partitions being revoked
PR-21989 - Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread
PR-21939 - Upgrade Jetty to 12.0.34 (trunk, 4.3, 4.2)
PR-21944 - Handle retriable partition errors gracefully on OffsetFetch
PR-21717 - Fix error invoking org.apache.kafka.connect.runtime.ConnectMetrics$MetricGroup.close()
PR-21642 - Add integration tests for group migration with compaction and broker restart
PR-21817 - StreamsGroupCommand should display committed offsets for repartition topics
PR-21757 - Limit SharePollEvent to single instance
PR-21740 - Receive buffers allocated from MemoryPool may not be released if request is invalid
PR-21782 - Add API version discovery true for transaction manager
PR-21619 - Controller registration needs to retry after request timeout
PR-21638 - Add upgrade guide warning about classic to streams group migration in 4.2.0
PR-21641 - Fix streams group creation failing when simple classic group exists
PR-21621 - Bump Jackson to 2.21.1
PR-21596 - ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls
PR-21559 - Downgrade Jetty from 12.0.32 to 12.0.25 to fix SLF4J 2.x incompatibility
ksqlDB
dd4efcba - Fix: reorder config resolver and validation for /is_valid_property
b496ed3b - Fix: ensure logging for property overrides before validation checks
cd3f8229 - Feat: add logging for user-supplied query overrides in restore mode
PR-11066 - Enforce DenyListPropertyValidator on in-SQL SET statements.
204c3441 - Fix: ensure invalid property values are checked before logging overrides
7537d0ab - Refactor: rename MDC_IN_ALLOWLIST to IN_ALLOWLIST for clarity
de04dfce - Feat: change logging level to DEBUG for no config overrides
3644c8f3 - Feat: log configuration overrides during command topic restore
371b0df8 - Feat: log configuration overrides for SET command
PR-11072 - Pin kotlin-stdlib via kotlin-bom to fix runtime crash in ksqldb
89684774 - Feat: log config overrides in InsertsStream and QueryStreamHandler
d7efcb03 - Feat: update ConfigOverrideLogger to static class
ecdee4a8 - Feat: add assertion for OverrideLogger to fire, before denylist check
3c444e34 - Feat: add OverrideLogger to /ws/query endpoint
9226ee95 - Feat: add OverrideLogger to /query endpoint
b14c7241 - Add ConfigOverrideLogger to StreamedQueryResource for logging config overrides
41a233f1 - Use CloseableThreadContext to log few extra fields apart from message.
09e60209 - Refactor
PR-11052 - TransientQueryCleanup leak-detection ordering + TransientQueryQueue LIMIT-handler null-guard
66c48859 - Add ConfigOverrideLogger for auditing property overrides on REST /ksql endpoint
PR-11049 - Netty bump
a5803cee - Update vertx and netty to resolve known security issues
PR-11033 - Fix: wait for broker to unfence in EmbeddedSingleNodeKafkaCluster.start()
PR-11030 - Fix: always retry admin stmts on topic-not-found, even with expectedError
PR-11029 - Fix: retry admin statements on transient topic-not-found errors
PR-11023 - Fix: KsqlTarget and SchemaRegistryUtil prefix collision
PR-11020 - Fix(build): bump protobuf-java runtime to 4.34.0 [8.0.x — cascade entry point]
PR-11015 - Merge Conflict Resolution (from 7.9.x to 8.0.x)
PR-11013 - Merge Conflict Resolution (from 7.4.x to 7.5.x)
PR-11014 - Feat(config): deprecate ksql.runtime.feature.shared.enabled
PR-11010 - Mark spotbugs-annotations as provided scope as they are only used for static code analysis.
PR-11009 - Fix type mismatch error for @JsonCreator. Wrap up the passed Map into ConcurrentHashMap internally.
e8475caf - Bump Netty to 4.1.132.Final
PR-10988 - Fix to prevent error when HTTP response fails in KsqlTarget
PR-10985 - Remove cc-docker-ksql as downstream branch
PR-10986 - Remove unused dependency for airlift.
PR-10980 - Minor fixes to accommodate Schema Registry changes
PR-10975 - Add a no arg constructor for ProtobufNoSRConverter
PR-10972 - Merge Conflict Resolution (from 7.5.x to 7.6.x)
PR-10971 - Remove duplicate definition for pr_ci_gating.
PR-10970 - Fix printTopic error when SSL is enabled
PR-10955 - Migrate KS OAuth handlers
f74de1ad - Backport pr_ci_gating and status_level from master to service.yml
2eef6c60 - Disable state updater in KsqlConfig due to known open-source bug in Kafka Streams
PR-10949 - Merge Conflict Resolution (from 8.1.x to 8.2.x)
PR-10935 - Add vert.x handler for unknown endpoints to return http 404.
PR-10939 - Fix(ci): increase agent size for cp-jar-build to fix disk space issue
PR-10936 - Bump up vert.x dependency version
PR-10932 - Update plugin version
PR-10928 - Bump log4j version
PR-10927 - Update jersey version
PR-10918 - Add deprecation tracking for external dependencies
PR-10920 - Update Netty
PR-10915 - Update jersey-client dependency
PR-10916 - CVE fix for jersey-client dependency.
REST Proxy
PR-1473 - Disable javaType resolution in JSONSCHEMA consumer (7.5.x)
PR-1462 - Fix error in test deserializers
PR-1456 - Remove ce-kafka-rest from downstream triggers on 8.2.x
94dbce1e - Fix ProduceActionRequestSizeLimitIntegrationTest
PR-1449 - Fix integration test failures (rate limit broken pipe, Jackson string length)
PR-1273 - Work around jackson databind string length limit
PR-708 - Remove ce-kafka-http-server from downstream trigger list (no 8.2.x branch exists)
PR-705 - Add explicit jetty-alpn-java-client version after common dropped jetty-bom (7.9.x)
PR-704 - Add explicit jetty-alpn-java-client version after common dropped jetty-bom (7.8.x)
e918b7a1 - Update async-http-client
9af8e309 - Remove Jackson definitions already present in common
b77450cc - Use mvn help:evaluate instead of regex for VERSION fallback
32898c8a - Tighten VERSION grep and drop unused mkdir BINPATH
PR-681 - Bump async-http-client to 2.14.5
PR-669 - Fix header validation to allow colons in header values
de983175 - Backport pr_ci_gating and status_level from master to service.yml
Schema Registry
c01d10c2 - Allow hard delete of subject versions even if association exists
11eb2119 - Ensure message indexes are not empty for Protobuf serialize
3b581ff6 - Fix: AssociatedNameStrategy.usesSchema() should reflect fallback strategy
PR-4326 - Add tenant enumeration and removal API to dek-registry MetricsManager
7d7d6954 - Enhance ParsedSchemaAndValue w/ writer schema and rule data
bbd699d9 - Adjust logging level in NONE action
6e2c0ce6 - Don’t mutate cached DEK when populating keyMaterial on createDek
6d017c31 - Test that createDek does not leave an orphan DEK on round-trip failure
3a5912bb - Round-trip shared DEK before persisting
555f8eb8 - Move RuleMetrics to metrics package
PR-4313 - Add size limit handler to limit req/resp size
PR-4312 - Add size limit handler
d7b9de1f - Add rule metrics to serdes
PR-4304 - Don’t kill leader-election thread on transient exceptions
57320568 - Add allow package config for JSON deserializer
cdd3ad81 - More variant changes
3795703b - Update variant fns
PR-4306 - Update access modifier for maybeValidateAndNormalizeSchema
17f05e97 - Add variants.isNull
fe5aeb56 - Change variants.at to path
4dfe82ba - Clean up dec fns
bfd4d025 - Add now var
29e86d98 - Reduce variant functions
e56011b0 - Modify decimals.prec
98ac85c3 - Add avro tests
56017bc4 - First cut at logical type functions
PR-4302 - Validate protobuf type references at registration time
ac404cb7 - Add config to passthru ciphertext if KEK is not shared
75b6c604 - Fix AWS KMS driver to use AssumeRoleWithWebIdentity in IRSA pods
b175693c - Ensure dry-run checks during mutateAssoc are idempotent
00a72b78 - Cleanup imports
b7751af3 - Fix ex handling
1086e407 - Add fail-fast
35dde324 - Allow regex to be configurable
ba69d465 - Add logical map to Avro
b205a035 - Replace nessie cel-java with google cel-java
abac2c4b - Allow arbitrary UTF-8 characters in Avro name validation
ae47835f - Fix spotless
248f39ca - Refactor integration tests
be8fcaa5 - Add deprecated flag
4eb4aca7 - Add test
e20b9755 - Fix comment
014f0702 - Fix lenient policy for JSON Schema compat
c5ee1ccd - Add meta.proto changes
d9c9fa28 - WIP validation rules
PR-4289 - AbstractDekRegistry: add polymorphic getKey/rangeKeys
1afc4bae - Allow frozen associations to be created during IMPORT
035a9d55 - Support multiple lifecycle filters for schemas w/assocs
25d73194 - Support URL-based truststore/keystore
PR-4285 - Fix Sonarqube in 8.0.x
PR-4282 - Add schema.reject.empty.subject config to reject empty subjects on register
e4465935 - Skip tombstoning of duplicate subject-versions if refs exist
c8053561 - Fix dep usage
29a3318c - Support public import for empty Proto schema
7ba56b0c - Add negative caches to CachedDekRegistryClient
f2237eb2 - Make $ref: #/$defs/X resolve consistently across JSON Schema drafts
560bf4ca - Handle anyOf/allOf in JSON transforms
PR-4274 - Make AbstractSchemaRegistry tolerate a null metadataEncoder
PR-4270 - Cleanup test logging
f01000e0 - Ensure names are validated with Avro 1.12
61b4c0a9 - Fix to reject invalid input
7515736b - Keep only one test
302bffda - Passing in correct policy for json schema compare
1ce7a540 - Ensure logical variant type is registered
PR-4264 - Extract association logic
e37f6be1 - Modify association API to allow get by resourceNamespace
be4a60ce - Add kafka-avro* packages
PR-4253 - Add toString() to KeyEncryptionKey and DataEncryptionKey
c73b2496 - Add default method
a27e2a3b - Add parameter to control order of adding/removing schema tags
66fa7588 - Remove debugging lines
a507f155 - Upgrade json-skema to 0.30.0
PR-4233 - Only leader perform deleted check for delete version api
PR-4246 - Add strict validation for empty metadata encoder secret
c3dd9236 - Parameter isKey not being threaded from converter to serializer
PR-4245 - Bump log4j core version
a6d6cf27 - Remove unneeded connect.type=variant
PR-4241 - Feat: add logging for metadata encoder secret loading and keyset serd
9747feba - Add protobuf types to sonar exclusions
6881d2a2 - Update jacoco deps
91d26587 - Fix avro naming
9bead003 - Fix ByteBuffer handling in VariantUtil and VariantBuilder
8a915642 - Fix JSON converter to use EmptySchema for variant
09d764e2 - Fix checkstyle/findbugs
096a2153 - Fix checkstyle
69e3b320 - Add connect support for Variant
00884d8f - Add variant to ProtobufSchema
PR-4240 - Fix: correct misleading error messages in getMode and getConfig
cf659c37 - Add Protobuf variant
PR-4239 - Move replaceAlias to AbstractSchemaRegistry for reuse
1812c39d - First cut at variant type
e1696fe9 - Fix possible error in AssociatedNameStrategy
f130b36c - Allow subjects to be null in SubjectKey/Value
2388975f - Add null checks in AssociationKey/Value
a8834dd0 - Ensure lifecycle is not null
6296c5da - Add missing call to applyDefaults
eebe020f - Remove unused code
3dbf3aaa - Fix test
aa690418 - Ensure idempotency of CREATE after partial failure
PR-4148 - DefaultToGlobal available in SRClient
ffb09d29 - Simplify applyDefaults
c4d884dc - Allow null subject during update
9564767b - Improve error message if subject does not match
a89b3891 - Explicitly set frozen=false on CREATE when no schema is provided
5c0ced01 - Qualify association subject before lookup in getLatestVersion
7879fe5c - Add additional client-side check for WEAK w/default name
613bcbb1 - Don’t default to WEAK for UPSERT
9f7ccf92 - Add JavaDoc
c7501ab2 - Handle minContains/maxContains
77347e2c - Capture minContains/maxContains
d95ee60e - Add additional enums
ad117566 - Add more frozen semantics
16984081 - Support unevaluatedProperties during JSON Schema compat
267e515e - Fix testes; relax strong checks for default subject
0c45aaaf - Fix build Rest Call Loggin Filter
bbcd0df0 - Default subject to :.namespace:name for frozen strong associations
35a251d9 - During upsert, ensure schema is not passed for WEAK
028e249c - Ensure schema is only passed for strong frozen
e2dcd5ce - Add configurable TTL to AssociatedNameStrategy cache
ecda6f91 - Rename
118b46ba - Nits
fedca30c - Change structire to filter
c055435c - Add rule object to exception
2db38bf3 - Add log warn if cluster id changes
b61980f3 - Remove use of AdminClient
47625d03 - Pass clusterId from producer/consumer to subject name strategy
a2d0b821 - Change header name
57cb3362 - Merge AdminAssociatedNameStrategy with superclass
PR-4223 - Fix UriPercentEncoder to correctly encode multi-byte Unicode characters
865f274c - Tests structure change
1c62d809 - Expose exporter name as part of logs in schema exporter destination
PR-4218 - Remove ce-kafka-rest from downstream triggers on 8.2.x
cdf6ef12 - Use topicId instead of clusterId in AdminAssociatedNameStrategy
108e27ab - Remove println
47f2ece1 - Fix compat check on circular ref for JSON Schema 2020-12-20
ac7cdaa8 - Add AssociatedNameStrategy that uses AdminClient
PR-4208 - Added SchemaRegistry method getAssociationsByResourceNamesp
PR-4207 - Fix incorrect OpenAPI example for getSchemaOnly endpoints
PR-4205 - Ensure parsed schema cache uses content-based key
PR-4202 - Prevent self-referencing schemas blocking subject level deletion with 42206
PR-4203 - Add config to validate before domain rules for JSON Schema
PR-4199 - Fix handling of JSON Schema with a single child
58036a98 - Add includeSchemas query parameter
1914cd7b - Add batch get to associations API
7a9f947e - Add serialize APIs that allow schema to be passed in
PR-4193 - Fix FindTags endpoint handling of JSON Schema with oneOf containing $ref
e9368714 - Minor refactoring of local Schema Registry client
3c4c4840 - Support schema ID in header with
use.schema.id=xxxconfigurationPR-4184 - Add UAMI OAuth integration to Schema Registry
8c28262c - Add configuration to disable envelope detection for JSON serialization
5dc789d4 - Minor renaming in AssociatedNameStrategy
7ee4ca5d - Handle null results in AssociatedNameStrategy
2e493aa0 - Add support for use.schema.guid config
PR-4162 - Ensure guid is preserved when formatting schema responses
PR-4156 - Fix race condition in deleteSubject API
PR-4159 - Increase timeout of 7.4.x build
16298931 - Add additional association request validation
89b3155e - Quote lang_version in service.yml to fix service-bot validation
00a7b2a0 - Return deleted/ts for /schemas endpoint
69c83b5a - Handle subjects named dek-registry for dek alias
93114a63 - Minor fixes for schema-id-in-header
PR-4146 - Update comments for 8.0 field description
PR-4141 - Update DEK registry sharedKeys wiring
52ac4f7c - Backport pr_ci_gating and status_level from master to service.yml
369bb852 - Handle tenant prefix in ContextFilter
PR-4137 - Swagger upgrade for Jakarta
PR-4135 - Context emptiness check should be done when the lock is held
742d06a5 - Minor renaming enableOnlyAt -> enableAt
7ff2d58d - Update frozen semantics for associations 1. Don’t allow frozen attribute to be update 2. Ensure schema is passed in for frozen association, and no other schemas exist for the subject 3. Ensure cascdadLifecycle=true when deleting frozen associations
791a821d - Support function param for Protobuf deserializer (pt 2)
PR-4128 - Handle null kafkaClusterId in MetricsContainer
b02bbb13 - Support function params for Protobuf/JSON Schema deserializers
bc4996d5 - Minor cleanup of exception handling
2fc7a28f - Add support for separate aliases for DEK lookups
3a3bea37 - Add integration test for creating KEK that already exists
68927075 - Add check for duplicate header in header serializer
79ad79c1 - Propagate SR client to embedded executor
388c3ef8 - Add createTs to Association
6bebdcc2 - Make AssociatedNameStrategy the default
88b49837 - Checkstyle lint
5f7409e0 - Fix params
ee3db7d4 - Reuse SR client for DEK Registry if possible
b303e043 - Add associations filter to /schemas endpoint
PR-4104 - Support x509 source
PR-4108 - Create AbstractDekRegistry for store-agnostic methods
d99f7722 - Add deleted query parm for referencedBy
ff340425 - Use ContextId instead of Integer
bbef4832 - Prevent hard-deletion of referenced schemas
Version 8.2.1
Released May 2026
Community Features
ksqlDB
Implemented a security fix for ksqlDB.
Schema Registry
Resolved a security vulnerability in io.confluent.kafka-json-schema-serializer
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