Confluent Platform Component Changelogs
This topic provides changelogs for the individual Confluent Platform components.
Version 8.0.4
Released February 2026
Community Features
Common
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
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
PR-887 - Update dependency org.apache.logging.log4j:log4j-core to v2.25.3
c33caa1b - Update Netty to 4.1.129
Kafka
PR-21462 - Upgrade Jetty from 12.0.22 to 12.0.32
PR-21397 - Add documentation about the incompatibility of RocksDB file format
PR-21438 - Improved error handling in DefaultStateUpdater.
PR-21421 - Close pending tasks on shutdown.
PR-21435 - Group coordinator fails to unload metadata when no longer leader or follower
PR-1897 - Update jetty to 12.0.32 in 4.0
PR-21374 - Made PartitionLeaderCache thread safe
PR-18662 - Allow use of ClusterInstance inside BeforeEach
8b3cc208 - Update jose4j version to 0.9.6
PR-20289 - Race condition between log segment flush and file deletion causing log dir to go offline
PR-21300 - Remove templateData.js in release.py
PR-1863 - org.glassfish.jersey.core:jersey-client in Kafka
PR-21287 - Fix rare producer message corruption, don’t reuse buffers
PR-21264 - Upgrade Log4j to 2.25.3
PR-21260 - Switched the java version for streams-scala from 17 to 11.
PR-21243 - Fix the broken quick start link
PR-21167 - Reset-by-duration should not hand back task to state-updater
PR-21135 - Gracefully handle exceptions when handling AllocateProducerIdsResponse
PR-21155 - TaskManager may not close all tasks on task timeouts
PR-21118 - Group coordinator loading may fail when there is concurrent compaction (4.0)
PR-21109 - Updating doc for process exceptional handler in case of global threads
PR-21035 - Update lz4 dependency version
PR-21105 - Upgrade commons-validator to 1.10.1
PR-20048 - OffsetFetch API does not return group level errors correctly with version 1
ksqlDB
PR-10944 - Fix pipeline reporting
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-10928 - Bump log4j version
PR-10927 - Update jersey version
PR-10918 - Add deprecation tracking for external dependencies
PR-10905 - Print deprecated configurations in maven builds.
REST Proxy
PR-1273 - Work around jackson databind string length limit
8171a366 - Fix partial permission issue for getConsumerGroups()
13fb1696 - Use .valid for listConsumerGroups() and fix some checkstyle issues
33f89369 - Fix partial permission issue for getConsumerGroups()
26da27f0 - Dependcy update: bump jersey-apache-connector to 3.1.11
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
Schema Registry
PR-4161 - Ensure guid is preserved when formatting schema responses
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
PR-4126 - Revert “Minor enhancement to display soft deleted versions as negative”
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
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
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
592a7db3 - Fix checkstyle
5e81d37d - Refactor assoc response creation
2c7c1cae - First cut at batch API improvements
6cec9889 - Add validateNewSchemas configuration
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 configuration 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
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 configuration “avro.fail.on.trailing.data”
1136f023 - Remove os
PR-4038 - Allow use.message.indexes to be set on ConfigSchemaIdDeserializer
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-4017 - Port setu 7.9
PR-4019 - Handle raw http in JSON Schema drafts
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
e5703b49 - Fix assert of 7.9 Junit
PR-4001 - Add support for recursive mode delete
Version 8.0.3
Released December 2025
Community Features
Common
PR-880 - Update dependency org.bouncycastle:bc-fips to v2.1.2 [SECURITY] (7.4.x)
2a944f44 - Use correct groupname for commons-lang3
04dd96c1 - Upgrade to Avro 1.12.1
fdad7f91 - Add azure keyvault-keys dependency to management section to match kafka
25ab4be8 - Fix the scope of imported pom
4eab14b4 - Update netty and bouncycastle
1b8bb0d3 - Add dependency management for grpc libraries and commons-lang3
92007c48 - Update jetty to 9.4.58.v20250814 in 7.9.3
8223daaa - Update jetty to 9.4.58.v20250814 in 7.8.4
6452c47a - Update jetty to 9.4.58.v20250814 in 7.7.5
6b641984 - Update jetty to 9.4.58.v20250814 in 7.6.7
2763e1a3 - Update jetty to 9.4.58.v20250814 in 7.5.10
8c5f24d8 - Update jetty to 9.4.58.v20250814 in 7.4.11
179e9ad6 - Update jetty to 9.4.58.v20250814 in 7.3.14
c3793950 - Update azure libraries
cd913d06 - Update netty to 4.1.125
61dac927 - Update netty to 4.1.125
dd5af737 - Update netty to 4.1.125
351727d4 - Update netty to 4.1.125
1e7d8099 - Update netty to 4.1.125
45817e38 - Update netty to 4.1.125
63d8206d - Update netty to 4.1.125
83c69d84 - Update netty to 4.1.225
bd24ec81 - Update netty to 4.1.225
3f2822ab - Update netty to 4.1.225
731e21af - Update netty to 4.1.225
6897f0eb - Update netty to 4.1.225
28503347 - Update netty to 4.1.225
06c00dc5 - Update netty to 4.1.225
de6eef11 - Update netty to 4.1.125
5efa5ead - Add httpclient5 and remove ZooKeeper
c6784097 - Upgrade protobuf to 31.1 to match ce-kafka
fdbb7f8a - Update bc-fips versions to match ce-kafka / latest security updates in verified fips version
348fe558 - Update jetty
a86ab6d5 - Update jetty, add bc-fips to renovatebot ignore file
PR-819 - Update dependency org.bouncycastle:bc-fips to v2.1.1 [SECURITY] (7.2.x)
Kafka
PR-20986 - Clamp negative values in coordinator histograms
PR-20939 - Removing process id from default client level tags
PR-20945 - Use eclipse-temurin as the base image to align with 3.9
PR-20926 - Regex subscription should be empty for classic members joining mixed group (4.0)
PR-20915 - Reintroduce SaslPlainSslEndToEndAuthorizationTest
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-20808 - Fix CoordinatorExecutorImpl.cancelAll implementation
PR-20258 - Set OP_WRITE interest after SASL reauthentication to resume pending writes
PR-18752 - Adding checkpointing for GlobalKTable during restoration and closing
PR-20715 - RecordTooLargeExceptions in group coordinator when offsets.topic.compression.codec is used (4.0)
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-20665 - Don’t fail if nextOffsetsAndMetadataToBeConsumed is not available
PR-20661 - Update ClientTelemetryReporter telemetry push error handling
ksqlDB
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 exceptions 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
cb2697ce - Bump up tcnative version to be in sync with netty
PR-10865 - Bump up tcnative dependency to be in sync with netty
PR-10854 - Update netty to 4.1.125
1be709ce - Update netty to 4.1.125 in 7.9.3
ece71da2 - Update netty to 4.1.125 in 7.8.4
f145df25 - Update netty to 4.1.125 in 7.7.5
9576ff68 - Update netty to 4.1.125 in 7.6.7
b7473128 - Update netty to 4.1.125 in 7.5.10
2f04c52c - Update netty to 4.1.125 in 7.4.11
c5dc9fd5 - Update netty to 4.1.125 in 7.3.14
PR-10833 - Set the order of timestamp fields to be processed to avoid incorrect modifications for daylight savings
PR-10845 - Unpin jackson version
PR-10841 - Unpin jackson version and upgrade shade plugin
PR-10831 - Fix ProcessValue and update historical plans
PR-10839 - Update dependency io.netty:netty-codec to v4.1.125.Final [SECURITY] (7.2.x)
fd1e276f - Update netty version
aa50267d - Update netty version
b00b4766 - Update netty version
1bd6fe9d - Update netty version
cf858512 - Update netty version
02310d14 - Update netty version
73f28ebd - Update netty version
d760e504 - Update netty version
a3f4c676 - Update netty version
53ee8cae - Update netty version
PR-10795 - Update dependency io.netty:netty-codec-http2 to v4.1.124.Final [SECURITY] (7.2.x)
PR-10808 - Added check for a compliant resource extension class name
PR-10802 - Pin httpclient 5 to correct one
ff42df17 - Update dependency io.netty:netty-codec-http2 to v4.1.124.Final [SECURITY]
REST Proxy
PR-1420 - Fix spotbug check issue
PR-1415 - Remove spotbug-annotations
PR-1409 - Prompt for community/open-source editions
a1096103 - Fix typo
fc9dae2d - Add tests
bd24ec6d - Feature flag for URI Compliance
7c66698b - Allow suspicious character
db84d15b - Update spiffe
PR-584 - Adding ProxyCustomizer for accessing tlvs
2c33bc9f - Make getSniServerName public
PR-611 - Adding ProxyCustomizer for accessing tlvs
c4281451 - Make getSniServerName public
Schema Registry
PR-4007 - Refactor ClusterTestHarness to extend generic SR test harness
PR-4004 - Allow function to be passed during Avro deserialization
PR-4003 - Add support for contextPrefix on list contexts API
PR-4001 - Add support for recursive mode delete
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-3985 - Remove addtional delta parameter from unit test
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-3947 - Remove sensitive schema data from thrown exceptions
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
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-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-3922 - REVERT: (Breaking API Change)
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-3912 - Refactor schema registry references from KafkaSchemaRegist
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-3904 - Ensure isKey is set for Avro/JSON key serializers
PR-3901 - Add golden file to test for MD5 regression
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-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-3880 - Fix exception when evolving Avro schema with rules
PR-3876 - Fix merge issue; add JavaDoc for invalidate methods
PR-3875 - Refine cache invalidation
PR-3868 - Only retry + throw exception on exception related to network connections
PR-3871 - Some fixes to tests/lints
PR-3870 - Add sr-version to sr client API
Version 8.0.2
Released October 2025
Community Features
Common
Kafka
PR-20646 - KAFKA-19510: clear pendingTasksToInit on tasks clear. (#20646)
PR-20616 - KAFKA-19719 –no-initial-controllers should not assume kraft.version=… (#20616)
PR-20621 - KAFKA-19390 Call safeForceUnmap() in AbstractIndex.resize() on Linux to prevent stale mmap of index files (#20621)
PR-20607 - KAFKA-19690 Add epoch check before verification guard check to prevent unexpected fatal error (#20607)
PR-20584 - [MINOR] Cleaning ignored streams test (#20584)
PR-20590 - KAFKA-19732, KAFKA-19716: Clear out coordinator snapshots periodically while loading (#20590)
PR-20580 - KAFKA-19546: Rebalance should be triggered by subscription change during group protocol downgrade (#20580)
ksqlDB
REST Proxy
Schema Registry
PR-3932 - REVERT: DGS-20986 - (Breaking API Change) (#3922)
Commercial Features
Connect
Bug fix: Confluent Enterprise distribution of Kafka Connect workers (CE, connect-server, or connect-server-base): Fixed a plugin class loading bug that prevented certain non-isolated classes (for example, javax.jms) from being loaded from plugin JARs. For more information, see article.
Version 8.0.1
Released September 2025
Community Features
Common
68339fe3 - Update Jetty
da44e9ae - Update netty to 4.1.125
PR-830 - Upgrade protobuf to 31.1 to match ce-kafka
94288a36 - Use correct versions of fips providers
PR-808 - adding license for assembly-plugin-boilerplate and build-tools modules
79dbce2c - Update jackson bom to match ce-kafka version
06637ab6 - Pin commons beanutils and validator
f11da56e - Upgrade spotbugs version
398fd1b3 - Update logredactor to address issues with versions 1 vs 2
Kafka
PR-20470 - processValue() must be declared as value-changing operation (#20470)
PR-1776 - Bump jetty to version 12.0.25 in 4.0
PR-1764 - Add run_tags to worker-ami and aws-packer
PR-1747 - Change ci_tools import path
PR-20269 - Fix typo in state-change log filename after rotate (#20269)
PR-20273 - State updater sensor names should be unique (#20262) (#20273)
PR-1707 - In case of infra failure in ccs-kafka tag that as infra failure in testbreak
PR-20165 - Update OpenJDK base image from buster to bullseye (#20165)
PR-20196 - Bump Commons-Lang (#20196)
PR-20176 - Cherrypick “MINOR : Handle error for client telemetry push (#19881)” (#20176)
PR-20040 - Allow the coordinator to grow its buffer dynamically (#20040)
PR-20166 - Remove unused metrics reporter initialization in KafkaAdminClient (#20166)
PR-20116 - Add back JoinGroup v0 & v1 (#20116)
PR-20072 - Propagate IOException on LogSegment#close (#20072)
PR-20102 - Backport TransactionsTest testBumpTransactionalEpochWithTV2Disabled failed on trunk (#20102)
PR-1673 - Exclude newly added files to fix build
PR-20026 - Backport to 4.0 (#20026)
PR-1664 - Add cloudwatch metrics to view cpu, memory and disk usage
PR-20034 - Handle the deleted topics when applying ClearElrRecord (#20034)
PR-19745 - Fix BrokerLifecycleManager RPC timeouts (#19745)
PR-19974 - Bug fix in deleteAcls operation
PR-19972 - Fix potential IllegalStateException when appending to timeIndex (#19972)
PR-1658 - Reapply “Remove deprecated KafkaBasedLog constructor (#18
PR-19991 - Follow up bug fix (#19991)
PR-1654 - Add back deprecated constructors in KafkaBasedLog
00a1b1e8 - Bump the commons-beanutils. Since commons-validator hasn’t had new release with newer commons-beanutils versions, we manually bump it in kafka.
PR-19817 - MetadataShell execution unintentionally deletes lock file (#19817)
ksqlDB
0f38153b - Bump up tcnative dependency.
8a9b3830 - Update netty to 4.1.125 in 8.0.1
707d2c90 - Update catch block to handle Throwable instead of Exception
PR-10808 - Added check for a compliant resource extension class name
PR-10831 - Fix ProcessValue and update historical plans
e9c70665 - Update json-smart version override comment
e1506346 - Updated dependency version override
PR-10789 - Changes to add License Validation plugin from CSP
PR-10791 - Add option to use local mode in proxy protocol headers.
PR-10782 - Improve configuration filtering for query overrides.
PR-10786 - Fix checkstyle errors.
PR-10785 - Apply proxy protocol configs to admin client.
PR-10781 - Pass the proxy protocol headers to admin, producer and consumer clients if the user principal is available.
PR-10779 - Bump the commons-lang3 version to 3.18.0
PR-10774 - Upgrade http components
PR-10765 - Adds apache kafka logger to rolling log4j2 yaml file
fbbfc142 - Suppress SIC_INNER_SHOULD_BE_STATIC04
a13a47da - Add suppression for PA_PUBLIC_PRIMITIVE_ATTRIBUTE, FS_BAD_DATE_FORMAT_FLAG_COMBO in findbugs-exclude.xml
e6450af9 - Suppress spotbug errors..
PR-10744 - Return a server error for host unavailability errors in pull queries.
REST Proxy
f05cee42 - Remove bc dependency that is being merged in bc-prov
PR-1403 - Hardcoding the CP rpm and deb installation dependency version
PR-586 - Fix jakarta usage in SpireTest.java
3d67bbc7 - Refactor comments
33f20c6e - Add comment to explain acceptAnySpiffeId
f390b052 - Add comment
2accbb1b - Fix SSL_IS_SPIRE_ENABLED_DOC and SSL_IS_SPIRE_ENABLED_DEFAULT
e57ff8da - Rename SSL_IS_SPIRE_ENABLED to SSL_SPIRE_ENABLED
8b340b25 - Add grpc-netty-linux to pom
2837a665 - Dependency modification
913fe83a - Add more constructor
e93773ec - Add new consturctor to application server
94b1e7bb - Add more comments for the sample HelloWorldSpireApplication
a7f06a76 - Make all the test to use SSL_CLIENT_AUTHENTICATION_CONFIG instead
d1992f62 - Revert extra variable for MTLS
2b569a12 - Fix HelloWorldSpireApplication style issue
99dfa601 - Remove socket path
d102c902 - Remove socketPath variable from config
e8fa0abe - Remove init X509 Source logic; changed to throw error instead
affb8342 - Create HelloWorldApplication with s2s based on spire
9e463ffb - Revert all changes made to HelloWorldApplication
6fcdf0f2 - Add more tests cases for spire Test
5392cec4 - Add option to be MTLS v.s TLS
27f06eb5 - Fix TestCustomizeThreadPool unit testing failure due to incorrect constructor building
62abe019 - Implement mock class in spire Test
b5ec6760 - Add null check
bb80e4e8 - Add 2 ways of application starting
8c6a02bb - Move X509source object to be in application server to prevent it getting closed
0a69aadd - Put x509 passing into the server
a470260f - Add spire setting for helloWorldApplication
e6ddc845 - Refactor x509source initilization to sslFactory
7b309f76 - Add config for spire related setting
f5b3cb4f - Modify spireTest to use spiffeFactoryContext
a14733fd - Modify HelloWorld Application to pass X509Source when init application
62f664bd - Modify application to take or initialize X509
35162aea - Mdofiy applicationserver to to take X509 source outside
ed3d2fca - sslFactory utilize SpiffeSslContextFactory instead of custom implementation
e73cc147 - Remove SpiffeTrustManager
6356cf0e - Add spire client test to do MTLS
1a5b4c6c - Make HelloWorldApplication using SSL
c4eb6a20 - Dependency pom xml
30763b96 - Modify server to make it connecting to spire agent
53e0fd45 - Add PREFIX_SNI_PREFIX_CONFIG
da8cf6fe - Restrict sni prefix validation to certain prefix
Schema Registry
PR-3899 - New sr endpoint client addition
PR-3894 - Remove protobuf.version in order to rely on the one from common (#3891)
PR-3864 - Organizing imports
PR-3863 - Fix assert equals usage for 8.0.x and greater
PR-3862 - Add deployment metadata endpoint
PR-3860 - Add sr type endpoint
PR-3837 - Hardcoding the CP rpm and deb installation dependency version
PR-3850 - Prevent re-registration of schema with dangling reference
PR-3851 - For shared KEKs avoid calling KMS when deleting DEKs
PR-3842 - Modify Schema Registry Client Config to convert all configs to string
PR-3840 - Fix build due to Jackson upgrade to 2.16
PR-3841 - Modify POST /subjects lookup to fail only if both normalize=true fails
PR-3838 - Upgrade json-sKema to 0.24.0
PR-3834 - Add descriptive logging for use of apache http client
PR-3832 - Close Schema registry after closing resource extensions
PR-3822 - Allow alternate KMS key IDs on a KEK
PR-3821 - upgrade commons lang version
PR-3825 - Add Apache and CCL licenses to the dek-* modules
PR-3815 - Add getGuid method to SchemaRegistryClient
752b07bc - Minor refactor to add subject to create DEK API
PR-3810 - Fix : Subject config and mode should be deleted on hard delete
PR-3816 - Ensure DEKs are decrypted if version=-1 for shared KEKs
PR-3814 - Replace MDC with ThreadContext for LOG4J2 compatibility
PR-3808 - Add support for JSON Schema 2020-12 in JsonSchemaUtils
PR-3777 - Add support for full payload encryption
PR-3787 - Changed resource logging to log subject name assotiation rather than hash contents
PR-3802 - Fix field traversals when POJO property is missing
PR-3794 - Handle decimals based on fixed type in Avro converter
PR-3763 - Add additional config for Apache Http Client
PR-3784 - Fix parsing of recursive definitions for JSON Schema 2020-12
PR-3773 - Send NetworkException instead of ConnectionException for IO exceptions in Connect converters
PR-3775 - Set cleanup.policy to compact in integration tests
9661d1af - Migrate test to Junit 5 after merge
PR-3766 - Support a true global config/mode
PR-3767 - Upgrade jackson-datatype-protobuf to 0.9.16
PR-3764 - Add REST API to delete context
PR-3760 - 7.8 below java doc fix
PR-3761 - Javadoc fix in ParsedSchema
PR-3758 - Add javadoc as part of the maven build
PR-3755 - Dix for javadoc failure
PR-3750 - Bump max DEK registry key default
PR-3746 - Generate correct field type for Decimal in JSON converter
PR-3744 - Add referenceFormat param to qualify references
PR-3738 - Send ConnectException for IO exceptions in connect converters
PR-3741 - Ensure correct GUID when requesting a formatted schema
42349149 - exposed context name for mode/config errors
PR-3736 - Suppressions and few volatile var changes to resolve spotbugs errors
PR-3735 - Add log4j-1.2-api dependency to SR
PR-3724 - Upgrade everit json-schema to 1.14.6
PR-3714 - Ensure SR client cache for CP 8.0 is backward compat with 7.x.x
Version 8.0.0
Released June 2025
Community Features
Common
69b3be7d - update logredactor for the log4j2 migration
44f2c2e4 - update jmx
c2dff5eb - remove zookeeper license / notice
33dd8114 - Update AWS SDK V2 to 2.29.39 for 8.0.x
5d925b59 - Update AWS SDK V2 to 2.27.9 for 7.9.x
PR-778 - Add property for AWS SDK v2
PR-777 - Use JDK 11 for client compatibilty
PR-776 - Emit Java 11 binaries while using JDK 17
4628a392 - fix of conflict merge resolution
467efd8f - fix missing version definition
cbc66130 - add commons-compress to unify versions with ce-kafka
0a1d3244 - update aws sdk to match ce-kafka
ae6ef1e3 - udpate amazonSdkVersion to match ce-kafka
PR-770 - Add slf4j-log4j binding dependency
61775ea0 - update jakarta to latest
b1cc00ad - Pin jakarta versions to support Jetty 12 migration
54d73bbe - update azure dependendecies to versions defined in azure-bom 1.2.32
60322b85 - upgrade jetty to major version 12 for the upcoming CP 8.0
PR-759 - Upgrade Protobuf to 4.29.3
fde07db0 - update netty to 4.1.118
f982ea91 - update bouncycastle dependencies
da33ed03 - fix the merge conflict
29819815 - update jetty to 9.4.57
ffe9fa48 - update bouncycastle to version 2.x for testing in CP
PR-743 - adding block level status for semaphore
PR-742 - Revert upgrade to Avro 1.12.0
130145e6 - Revert “upgrade sem java version to 17 as we already upgraded to 17 here.”
4b2f8e9b - upgrade sem java version to 17 as we already upgraded to 17 here. https://github.com/confluentinc/common/blob/master/.semaphore/semaphore.yml#L79
6a98be70 - update netty to 4.1.115
34310351 - revert bouncycastle bctls due to downstream failues
34f3ad49 - update java to version 17 and avro
Kafka
PR-19790 - KAFKA-18687: Setting the subscriptionMetadata during conversion to consumer group (#19790)
PR-19658 - KAFKA-18345; Prevent livelocked elections (#19658)
PR-19507 - KAFKA-19171: Kafka Streams crashes with UnsupportedOperationException (#19507)
PR-19580 - KAFKA-19208: KStream-GlobalKTable join should not drop left-null-key record (#19580)
PR-19713 - KAFKA-19274; Group Coordinator Shards are not unloaded when __consumer_offsets topic is deleted (#19713)
PR-19712 - KAFKA-19275 client-state and thread-state metrics are always “Unavailable” (#19712)
PR-19677 - KAFKA-18688: Fix uniform homogeneous assignor stability (#19677)
PR-19496 - KAFKA-19163: Avoid deleting groups with pending transactional offsets (#19496)
PR-19497 - KAFKA-19160;KAFKA-19164; Improve performance of fetching stable offsets (#19497)
PR-1623 - Ignore failing quota_test
PR-19629 - KAFKA-19131: Adjust remote storage reader thread maximum pool size to avoid illegal argument (#19629)
PR-1620 - Dexcom fix 4.0
PR-19555 - KAFKA-19195: Only send the right group ID subset to each GC shard (#19555)
PR-19545 - KAFKA-19192; Old bootstrap checkpoint files cause problems updated servers (#19545)
PR-19518 - KAFKA-19166: Fix RC tag in release script (#19518)
PR-1613 - CONFLUENT: Fix tools-log4j files names in the scripts
PR-19394 - KAFKA-19054: StreamThread exception handling with SHUTDOWN_APPLICATION may trigger a tight loop with MANY logs (#19394)
PR-19488 - KAFKA-19147: Start authorizer before group coordinator to ensure coordinator authorizes regex topics (#19488)
PR-19345 - KAFKA-19071: Fix doc for remote.storage.enable (#19345)
PR-19188 - KAFKA-18962: Fix onBatchRestored call in GlobalStateManagerImpl (#19188)
83f6a1d7 - KAFKA-18991; Missing change for cherry-pick
PR-19223 - KAFKA-18991: FetcherThread should match leader epochs between fetch request and fetch state (#19223)
PR-18852 - KAFKA-18723; Better handle invalid records during replication (#18852)
PR-1611 - Fix build failure (#1582)
PR-19213 - KAFKA-18984: Reset interval.ms By Using kafka-client-metrics.sh (#19213)
PR-19303 - KAFKA-16407: Fix foreign key INNER join on change of FK from/to a null value (#19303)
PR-19269 - KAFKA-18067: Add a flag to disable producer reset during active task creator shutting down (#19269)
PR-19331 - KAFKA-15931: Cancel RemoteLogReader gracefully (#19331)
PR-18842 - KAFKA-806 Index may not always observe log.index.interval.bytes (#18842)
PR-19212 - KAFKA-18993 Remove confusing notable change section from upgrade.html (#19212)
PR-19164 - KAFKA-18943: Kafka Streams incorrectly commits TX during task revokation (#19164)
PR-19205 - KAFKA-18979; Report correct kraft.version in ApiVersions (#19205)
PR-19119 - KAFKA-18422 Adjust Kafka client upgrade path section (#19119)
PR-18091 - KAFKA-18074: Add kafka client compatibility matrix (#18091)
PR-18258 - KAFKA-18195: Fix Kafka Streams broker compatibility matrix (#18258)
PR-19156 - KAFKA-18940: fix electionWasClean (#19156)
PR-19127 - KAFKA-18920: The kcontrollers must set kraft.version in ApiVersionsResponse (#19127)
PR-19138 - KAFKA-18046; High CPU usage when using Log4j2 (#19138)
PR-19131 - KAFKA-18648: Make records in FetchResponse nullable again (#19131)
4a500418 - Revert “KAFKA-18246 Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs (#18191)”
PR-19104 - KAFKA-18919 Clarify that KafkaPrincipalBuilder classes must also implement KafkaPrincipalSerde (#19104)
PR-19087 - KAFKA-18886 add behavior change of CreateTopicPolicy and AlterConfigPolicy to zk2kraft (#19087)
PR-19097 - KAFKA-18422 add link of KIP-1124 to “rolling upgrade” section (#19097)
PR-19065 - KAFKA-18876 4.0 documentation improvement (#19065)
PR-19088 - KAFKA-18916; Resolved regular expressions must update the group by topics data structure (#19088)
PR-18997 - KAFKA-18844: Stale features information in QuorumController#registerBroker (#18997)
PR-19036 - KAFKA-18864:remove the Evolving tag from stable public interfaces (#19036)
PR-19067 - KAFKA-18908 Document that the size of appended value can’t be larger than Short.MAX_VALUE (#19067)
PR-19048 - KAFKA-18860 Remove Missing Features section (#19048)
PR-19037 - KAFKA-18869 add remote storage threads to “Updating Thread Configs” section (#19037)
PR-19042 - KAFKA-18813: ConsumerGroupHeartbeat API and ConsumerGroupDescribe API… (#19042)
PR-18988 - KAFKA-18839: Drop EAGER rebalancing support in Kafka Streams (#18988)
PR-18387 - KAFKA-18281: Kafka is improperly validating non-advertised listeners for routable controller addresses (#18387)
PR-18898 - KIP-966 part 1 release doc (#18898)
PR-18880 - KAFKA-15583 doc update for the “strict min ISR” rule (#18880)
PR-19000 - Revert “KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#16295)” (#19000)
PR-18996 - KAFKA-18813: [3/N] Client support for TopicAuthException in DescribeConsumerGroup path (#18996)
PR-18986 - KAFKA-18813: [2/N] Client support for TopicAuthException in HB path (#18986)
PR-18844 - KAFKA-18737 KafkaDockerWrapper setup functions fails due to storage format command (#18844)
PR-18982 - KAFKA-18829: Added check before converting to IMPLICIT mode (#18964) (Cherry-pick) (#18982)
PR-18969 - KAFKA-18831 Migrating to log4j2 introduce behavior changes of adjusting level dynamically (#18969)
PR-18737 - KAFKA-18641: AsyncKafkaConsumer could lose records with auto offset commit (#18737)
PR-18845 - KAFKA-18601: Assume a baseline of 3.3 for server protocol versions (#18845)
PR-18872 - KAFKA-18773 Migrate the log4j1 config to log4j 2 for native image and README (#18872)
PR-18934 - KAFKA-18807; Fix thread idle ratio metric (#18934)
PR-18889 - KAFKA-18784 Fix ConsumerWithLegacyMessageFormatIntegrationTest (#18889)
PR-18916 - KAFKA-18803 The acls would appear at the wrong level of the metadata shell “tree” (#18916)
PR-18906 - KAFKA-18790 Fix testCustomQuotaCallback (#18906)
PR-18680 - KAFKA-18634: Fix ELR metadata version issues (#18680)
PR-18795 - KAFKA-17182: Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer (#18795)
PR-18810 - KAFKA-18654[2/2]: Transction V2 retry add partitions on the server side when handling produce request. (#18810)
PR-18756 - KAFKA-17298: Update upgrade notes for 4.0 KIP-848 (#18756)
PR-18275 - KAFKA-15443: Upgrade RocksDB to 9.7.3 (#18275)
PR-18394 - KAFKA-18396: Migrate log4j1 configuration to log4j2 in KafkaDockerWrapper (#18394)
PR-18820 - KAFKA-18366 Remove KafkaConfig.interBrokerProtocolVersion (#18820)
PR-18821 - KAFKA-18743 Remove leader.imbalance.per.broker.percentage as it is not supported by Kraft (#18821)
PR-1579 - CCS CP release test regex updates
PR-1578 - CCS CP release test regex updates
PR-18843 - KAFKA-806 Index may not always observe log.index.interval.bytes (#18843)
PR-18196 - KAFKA-18225 ClientQuotaCallback#updateClusterMetadata is unsupported by kraft (#18196)
PR-18252 - KAFKA-17833: Convert DescribeAuthorizedOperationsTest to use KRaft (#18252)
PR-18818 - KAFKA-18741 document the removal of inter.broker.protocol.version (#18818)
PR-18566 - KAFKA-18360 Remove zookeeper configurations (#18566)
PR-18641 - KAFKA-18530 Remove ZooKeeperInternals (#18641)
PR-18583 - KAFKA-18499 Clean up zookeeper from LogConfig (#18583)
PR-18189 - KAFKA-18206: EmbeddedKafkaCluster must set features (#18189)
PR-18702 - KAFKA-18645: New consumer should align close timeout handling with classic consumer (#18702)
PR-18781 - KAFKA-18675 Add tests for valid and invalid broker addresses (#18781)
PR-18767 - KAFKA-18675 Add unit test to verify space separated brokers won’t cause exception for 3.8 and 3.9 (#18767)
PR-18304 - KAFKA-16524; Metrics for KIP-853 (#18304)
PR-18277 - KAFKA-18635: reenable the unclean shutdown detection (#18277)
PR-18708 - KAFKA-18649: complete ClearElrRecord handling (#18708)
PR-18148 - KAFKA-16540: Clear ELRs when min.insync.replicas is changed. (#18148)
PR-17952 - KAFKA-16540: enforce min.insync.replicas config invariants for ELR (#17952)
PR-15622 - KAFKA-16446: Improve controller event duration logging (#15622)
PR-18028 - KAFKA-18131: Improve logs for voters (#18028)
PR-18222 - KAFKA-18305: validate controller.listener.names is not in inter.broker.listener.name for kcontrollers (#18222)
PR-18777 - KAFKA-18690: Keep leader metadata for RE2J-assigned partitions (#18777)
PR-17836 - KAFKA-18028 the effective kraft version of –no-initial-controllers should be 1 rather than 0 (#17836)
PR-18165 - KAFKA-18230: Handle not controller or not leader error in admin client (#18165)
PR-17773 - KAFKA-18001: Support UpdateRaftVoterRequest in KafkaNetworkChannel (#17773)
PR-18720 - KAFKA-18654 [1/2]: Transaction Version 2 performance regression due to early return (#18720)
PR-18592 - KAFKA-18545: Remove Zookeeper logic from LogManager (#18592)
PR-18786 - KAFKA-18672; CoordinatorRecordSerde must validate value version (4.0) (#18786)
PR-18717 - KAFKA-18655: Implement the consumer group size counter with scheduled task (#18717)
PR-18764 - KAFKA-18685: Cleanup DynamicLogConfig constructor (#18764)
PR-18785 - KAFKA-18676; Update Benchmark system tests (#18785)
PR-18330 - KAFKA-17631 Convert SaslApiVersionsRequestTest to kraft (#18330)
PR-18768 - KAFKA-18678 Update TestVerifiableProducer system test (#18768)
PR-18751 - KAFKA-18674 Document the incompatible changes in parsing –bootstrap-server (#18751)
PR-18727 - KAFKA-18659: librdkafka compressed produce fails unless api versions returns produce v0 (#18727)
fc3dca4e - Revert “KAFKA-17182: Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer (#17700)”
PR-18758 - KAFKA-18660: Transactions Version 2 doesn’t handle epoch overflow correctly (#18730) (#18758)
PR-18750 - KAFKA-18320; Ensure that assignors are at the right place (#18750)
PR-17700 - KAFKA-17182: Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer (#17700)
PR-18766 - KAFKA-18146; tests/kafkatest/tests/core/upgrade_test.py needs to be re-added as KRaft (#18766)
PR-18763 - KAFKA-18677; Update ConsoleConsumerTest system test (#18763)
PR-18754 - KAFKA-18034: CommitRequestManager should fail pending requests on fatal coordinator errors (#18754)
PR-1556 - MINOR: Disable publish artifacts for 4.0
PR-18731 - KAFKA-18570: Update documentation to add remainingLogsToRecover, remainingSegmentsToRecover and LogDirectoryOffline metrics (#18731)
PR-18741 - KAFKA-18171: Revert the strict config validation for 3.8 and 3.9 (#18741)
PR-18590 - KAFKA-18569: New consumer close may wait on unneeded FindCoordinator (#18590)
PR-18314 - KAFKA-16339: Add Kafka Streams migrating guide from transform to process (#18314)
PR-18478 - KAFKA-18383 Remove reserved.broker.max.id and broker.id.generation.enable (#18478)
PR-18733 - KAFKA-18662: Return CONCURRENT_TRANSACTIONS on produce request in TV2 (#18733)
PR-18726 - KAFKA-18646: Null records in fetch response breaks librdkafka (#18726)
PR-18736 - KAFKA-18663: Metadata v0-v3 should be undeprecated (#18736)
PR-18668 - KAFKA-18619: New consumer topic metadata events should set requireMetadata flag (#18668)
PR-18716 - KAFKA-18648: Add back support for metadata version 0-3 (#18716)
PR-1553 - [3.9] Update jetty to 9.4.57.v20241219
PR-18555 - KAFKA-18528: MultipleListenersWithSameSecurityProtocolBaseTest and GssapiAuthenticationTest should run for async consumer (#18555)
PR-18602 - KAFKA-17587 Refactor test infrastructure (#18602)
PR-18690 - KAFKA-18597 Fix max-buffer-utilization-percent is always 0 (#18690)
PR-17510 - KAFKA-17792: Efficiently parse decimals with large exponents in Connect Values (#17510)
PR-18539 - KAFKA-18454 Publish build scans to develocity.apache.org (#18539)
PR-18693 - KAFKA-18631 Remove ZkConfigs (#18693)
PR-18547 - KAFKA-18533 Remove KafkaConfig zookeeper related logic (#18547)
PR-18687 - KAFKA-18630: Clean ReplicaManagerBuilder (#18687)
PR-18621 - KAFKA-18592 Cleanup ReplicaManager (#18621)
PR-18477 - KAFKA-18474: Remove zkBroker listener (#18477)
PR-18630 - KAFKA-18599: Remove Optional wrapping for forwardingManager in ApiVersionManager (#18630)
PR-18667 - KAFKA-18484 [2/2]; Handle exceptions during coordinator unload (#18667)
PR-18666 - KAFKA-18486; [1/2] Update LocalLeaderEndPointTest (#18666)
PR-18532 - KAFKA-18517: Enable ConsumerBounceTest to run for new async consumer (#18532)
PR-18614 - KAFKA-18519: Remove Json.scala, cleanup AclEntry.scala (#18614)
PR-18389 - KAFKA-18229: Move configs out of “kraft” directory (#18389)
PR-18629 - KAFKA-18598: Remove ControllerMetadataMetrics ZK-related Metrics (#18629)
PR-18631 - KAFKA-18595: Remove AuthorizerUtils#sessionToRequestContext (#18631)
PR-18661 - KAFKA-18484 [1/N]; Handle exceptions from deferred events in coordinator (#18661)
PR-18657 - KAFKA-18583; Fix getPartitionReplicaEndpoints for KRaft (#18657)
PR-18607 - KAFKA-17402: DefaultStateUpdated should transite task atomically (#18607)
PR-18587 - KAFKA-8862: Improve Producer error message for failed metadata update (#18587)
PR-18581 - KAFKA-17561: add processId tag to thread-state metric (#18581)
PR-18647 - KAFKA-18487; Remove ReplicaManager#stopReplicas (#18647)
PR-18635 - KAFKA-18583; Fix getPartitionReplicaEndpoints for KRaft (#18635)
PR-18485 - Cherrypick lock backoff retry to 3.9 (#18485)
PR-18497 - KAFKA-14552: Assume a baseline of 3.0 for server protocol versions (#18497)
PR-18340 - KAFKA-18339: Fix parseRequestHeader error handling (#18340)
PR-18643 - Revert “KAFKA-18404: Remove partitionMaxBytes usage from DelayedShareFetch (#17870)” (#18643)
PR-18346 - KAFKA-18363: Remove ZooKeeper mentiosn in broker configs (#18346)
PR-18628 - KAFKA-18578: Remove UpdateMetadataRequest from MetadataCacheTest (#18628)
PR-18567 - KAFKA-18553: Update javadoc and comments of ConfigType (#18567)
PR-18624 - KAFKA-18588 Remove TopicKey.scala (#18624)
PR-17390 - KAFKA-17668: Clean-up LogCleaner#maxOverCleanerThreads and LogCleanerManager#maintainUncleanablePartitions (#17390)
PR-18613 - KAFKA-18427: Remove ZooKeeperClient (#18613)
PR-18591 - KAFKA-18540: Remove UpdataMetadataRequest from KafkaApisTest (#18591)
PR-18594 - KAFKA-18532: Clean Partition.scala zookeeper logic (#18594)
PR-18605 - KAFKA-18423: Remove ZkData and related unused references (#18605)
PR-18616 - KAFKA-18429 Remove ZkFinalizedFeatureCache and StateChangeFailedException (#18616)
PR-18619 - KAFKA-18589 Remove unused interBrokerProtocolVersion from GroupMetadataManager (#18619)
PR-18598 - KAFKA-18516 Remove RackAwareMode (#18598)
PR-18608 - KAFKA-18492 Cleanup RequestHandlerHelper (#18608)
PR-18586 - KAFKA-18565 Cleanup SaslSetup (#18586)
PR-18606 - KAFKA-18430 Remove ZkNodeChangeNotificationListener (#18606)
PR-18595 - KAFKA-18515 Remove DelegationTokenManagerZk (#18595)
PR-18492 - KAFKA-18480 Fix fail e2e test_offset_truncate (#18492)
PR-18524 - KAFKA-18514: Refactor share module code to server and server-common (#18524)
PR-17870 - KAFKA-18404: Remove partitionMaxBytes usage from DelayedShareFetch (#17870)
PR-18240 - KAFKA-17642: PreVote response handling and ProspectiveState (#18240)
PR-18585 - KAFKA-18413: Remove AdminZkClient (#18585)
PR-18406 - KAFKA-18318: Add logs for online/offline migration indication (#18406)
PR-18224 - KAFKA-18150; Downgrade group on classic leave of last consumer member (#18224)
PR-18573 - KAFKA-18431: Remove KafkaController (#18573)
PR-18565 - KAFKA-18546: Use mocks instead of a real DNS lookup to the outside (#18565)
PR-18553 - KAFKA-18373: Remove ZkMetadataCache (#18553)
PR-18574 - KAFKA-18407: Remove ZkAdminManager, DelayedCreatePartitions, CreatePartitionsMetadata, ZkConfigRepository, DelayedDeleteTopics (#18574)
PR-18568 - KAFKA-18556: Remove JaasModule#zkDigestModule, JaasTestUtils#zkSections (#18568)
PR-18140 - KAFKA-16368: Add a new constraint for segment.bytes to min 1MB for KIP-1030 (#18140)
PR-18106 - KAFKA-16368: Update defaults for LOG_MESSAGE_TIMESTAMP_AFTER_MAX_MS_DEFAULT and NUM_RECOVERY_THREADS_PER_DATA_DIR_CONFIG (#18106)
PR-18535 - KAFKA-18521 Cleanup NodeApiVersions zkMigrationEnabled field (#18535)
PR-18552 - KAFKA-18542 Cleanup AlterPartitionManager (#18552)
PR-18561 - KAFKA-18406 Remove ZkBrokerEpochManager.scala (#18561)
PR-18508 - KAFKA-18405 Remove ZooKeeper logic from DynamicBrokerConfig (#18508)
PR-18080 - KAFKA-16368: Update default linger.ms to 5ms for KIP-1030 (#18080)
PR-18414 - KAFKA-18331: Make process.roles and node.id required configs (#18414)
PR-18483 - KAFKA-18472: Remove MetadataSupport (#18483)
PR-18536 - KAFKA-18514 Remove server dependency on share coordinator (#18536)
PR-18365 - KAFKA-18364 add document to show the changes of metrics and configs after removing zookeeper (#18365)
PR-18550 - KAFKA-18539 Remove optional managers in KafkaApis (#18550)
PR-18563 - use version.py get_version to get version (#18563)
PR-18490 - KAFKA-18479: RocksDBTimeOrderedKeyValueBuffer not initialized correctly (#18490)
PR-18448 - KAFKA-18401: Transaction version 2 does not support commit transaction without records (#18448)
155d7720 - HOTIFX: fix broken build
PR-18542 - KAFKA-18399 Remove ZooKeeper from KafkaApis (12/N): clean up ZKMetadataCache, KafkaController and raftSupport (#18542)
PR-18386 - KAFKA-18346 Fix e2e TestKRaftUpgrade for v3.3.2 (#18386)
21c4539d - Revert “KAFKA-18034: CommitRequestManager should fail pending requests on fatal coordinator errors (#18050)”
PR-18530 - KAFKA-18520: Remove ZooKeeper logic from JaasUtils (#18530)
PR-18540 - KAFKA-18399 Remove ZooKeeper from KafkaApis (11/N): CREATE_ACLS and DELETE_ACLS (#18540)
PR-18432 - KAFKA-18399 Remove ZooKeeper from KafkaApis (10/N): ALTER_CONFIG and INCREMENETAL_ALTER_CONFIG (#18432)
PR-18487 - KAFKA-18476: KafkaStreams should swallow TransactionAbortedException (#18487)
PR-18195 - KAFKA-18026: KIP-1112, clean up StatefulProcessorNode (#18195)
PR-18150 - KAFKA-18026: KIP-1112 migrate KTableSuppressProcessorSupplier (#18150)
PR-18518 - KAFKA-18502 Remove kafka.controller.Election (#18518)
PR-18281 - KAFKA-18330: Update documentation to remove controller deployment limitations (#18281)
PR-18465 - KAFKA-18399 Remove ZooKeeper from KafkaApis (9/N): ALTER_CLIENT_QUOTAS and ALLOCATE_PRODUCER_IDS (#18465)
PR-18453 - KAFKA-18399 Remove ZooKeeper from KafkaApis (8/N): ELECT_LEADERS , ALTER_PARTITION, UPDATE_FEATURES (#18453)
PR-18403 - KAFKA-18211: Override class loaders for class graph scanning in connect. (#18403)
PR-17669 - KAFKA-17915: Convert Kafka Client system tests to use KRaft (#17669)
PR-18507 - KAFKA-18491 Remove zkClient & maybeUpdateMetadataCache from ReplicaManager (#18507)
0186534a - Revert “KAFKA-17411: Create local state Standbys on start (#16922)” and “KAFKA-17978: Fix invalid topology on Task assignment (#17778)”
PR-18475 - KAFKA-18469;KAFKA-18036: AsyncConsumer should request metadata update if ListOffsetRequest encounters a retriable error (#18475)
PR-17728 - KAFKA-17973: Relax Restriction for Voters Set Change (#17728)
PR-18050 - KAFKA-18034: CommitRequestManager should fail pending requests on fatal coordinator errors (#18050)
PR-18504 - KAFKA-18485; Update log4j2.yaml (#18504)
PR-18433 - KAFKA-18399 Remove ZooKeeper from KafkaApis (7/N): CREATE_TOPICS, DELETE_TOPICS, CREATE_PARTITIONS (#18433)
PR-18320 - KAFKA-18341: Remove KafkaConfig GroupType config check and warn log (#18320)
PR-18447 - KAFKA-18399 Remove ZooKeeper from KafkaApis (6/N): handleCreateTokenRequest, handleRenewTokenRequestZk, handleExpireTokenRequestZk (#18447)
PR-18464 - KAFKA-18399 Remove ZooKeeper from KafkaApis (5/N): ALTER_PARTITION_REASSIGNMENTS, LIST_PARTITION_REASSIGNMENTS (#18464)
PR-18461 - KAFKA-18399 Remove ZooKeeper from KafkaApis (4/N): OFFSET_COMMIT and OFFSET_FETCH (#18461)
PR-18456 - KAFKA-18399 Remove ZooKeeper from KafkaApis (3/N): USER_SCRAM_CREDENTIALS (#18456)
PR-18472 - KAFKA-18466 Remove log4j-1.2-api from runtime scope while keeping it in distribution package (#18472)
PR-18437 - KAFKA-18446 Remove MetadataCacheControllerNodeProvider (#18437)
PR-18468 - KAFKA-18465: Remove MetadataVersions older than 3.0-IV1 (#18468)
PR-18467 - KAFKA-18464: Empty Abort Transaction can fence producer incorrectly with Transactions V2 (#18467)
PR-18471 - KAFKA-8116: Update Kafka Streams archetype for Java 11 (#18471)
PR-18378 - KAFKA-18340: Change Dockerfile to use log4j2 yaml instead log4j properties (#18378)
PR-17454 - KAFKA-17671: Create better documentation for transactions (#17454)
PR-18422 - KAFKA-18399 Remove ZooKeeper from KafkaApis (2/N): CONTROLLED_SHUTDOWN and ENVELOPE (#18422)
PR-18146 - KAFKA-18073: Prevent dropped records from failed retriable exceptions (#18146)
PR-18321 - KAFKA-13093: Log compaction should write new segments with record version v2 (KIP-724) (#18321)
PR-18100 - KAFKA-18180: Move OffsetResultHolder to storage module (#18100)
PR-17527 - KAFKA-17455: fix stuck producer when throttling or retrying (#17527)
PR-18367 - KAFKA-17915: Convert remaining Kafka Client system tests to use KRaft (#18367)
PR-18247 - KAFKA-18277 Convert network_degrade_test to Kraft mode (#18247)
PR-18445 - KAFKA-18445 Remove LazyDownConversionRecords and LazyDownConversionRecordsSend (#18445)
PR-18417 - KAFKA-18399 Remove ZooKeeper from KafkaApis (1/N): LEADER_AND_ISR, STOP_REPLICA, UPDATE_METADATA (#18417)
PR-18382 - KAFKA-17730 ReplicaFetcherThreadBenchmark is broken (#18382)
PR-18423 - KAFKA-18437: Correct version of ShareUpdateRecord value (#18423)
PR-18457 - KAFKA-18397: Added null check before sending background event from ShareConsumeRequestManager. (#18419) (#18457)
PR-18462 - KAFKA-18449: Add share group state configs to reconfig-server.properties (#18440) (#18462)
PR-18450 - KAFKA-18435 Remove zookeeper dependencies in build.gradle (#18450)
PR-18438 - KAFKA-18432 Remove unused code from AutoTopicCreationManager (#18438)
PR-18441 - KAFKA-18426 Remove FinalizedFeatureChangeListener (#18441)
PR-18443 - KAFKA-18425 Remove OffsetTrackingListener (#18443)
PR-18428 - Backport some GHA changes from trunk (#18428)
PR-18329 - KAFKA-18353 Remove zk config control.plane.listener.name (#18329)
PR-18429 - KAFKA-18443 Remove ZkFourLetterWords (#18429)
PR-18431 - KAFKA-18417 Remove controlled.shutdown.max.retries and controlled.shutdown.retry.backoff.ms (#18431)
PR-18287 - KAFKA-18326: fix merge iterator with cache tombstones (#18287)
PR-18413 - KAFKA-18411 Remove ZkProducerIdManager (#18413)
PR-18401 - KAFKA-18414 Remove KRaftRegistrationResult (#18401)
PR-17671 - KAFKA-17921 Support SASL_PLAINTEXT protocol with java.security.auth.login.config (#17671)
PR-18411 - KAFKA-18436: Revert Multiversioning Changes from 4.0 release. (#18411)
PR-18364 - KAFKA-18384 Remove ZkAlterPartitionManager (#18364)
PR-18399 - KAFKA-18412: Remove EmbeddedZookeeper (#18399)
PR-18352 - KAFKA-18368 Remove TestUtils#MockZkConnect and remove zkConnect from TestUtils#createBrokerConfig (#18352)
PR-18370 - KAFKA-18388 test-kraft-server-start.sh should use log4j2.yaml (#18370)
PR-18355 - KAFKA-18374 Remove EncryptingPasswordEncoder, CipherParamsEncoder, GcmParamsEncoder, IvParamsEncoder, and the unused static variables in PasswordEncoder (#18355)
PR-18384 - KAFKA-17616: Remove KafkaServer (#18384)
PR-18353 - KAFKA-18365 Remove zookeeper.connect in Test (#18353)
PR-18363 - KAFKA-18367 Remove ZkConfigManager (#18363)
PR-18351 - KAFKA-18347 Add tools-log4j2.yaml to config and remove unsed tools-log4j.properties from config (#18351)
PR-18359 - KAFKA-18375 Update the LICENSE-binary (#18359)
PR-18345 - KAFKA-18026: KIP-1112, configure all StoreBuilder & StoreFactory layers (#18345)
PR-18347 - KAFKA-18361 Remove PasswordEncoderConfigs (#18347)
PR-18271 - KAFKA-17615 Remove KafkaServer from tests (#18271)
PR-18308 - KAFKA-18280 fix e2e TestSecurityRollingUpgrade.test_rolling_upgrade_sasl_mechanism_phase_one (#18308)
PR-18327 - KAFKA-18313 Fix to Kraft or remove tests associate with Zk Broker config in SocketServerTest and ReplicaFetcherThreadTest (#18327)
PR-18279 - KAFKA-18316 Fix to Kraft or remove tests associate with Zk Broker config in ConnectionQuotasTest (#18279)
PR-18185 - KAFKA-18243 Fix compatibility of Loggers class between log4j and log4j2 (#18185)
PR-18269 - KAFKA-18315 Fix to Kraft or remove tests associate with Zk Broker config in DynamicBrokerConfigTest, ReplicaManagerTest, DescribeTopicPartitionsRequestHandlerTest, KafkaConfigTest (#18269)
PR-18338 - KAFKA-18354 Use log4j2 APIs to refactor LogCaptureAppender (#18338)
PR-18309 - KAFKA-18314 Fix to Kraft or remove tests associate with Zk Broker config in KafkaApisTest (#18309)
PR-18344 - KAFKA-18359 Set zkConnect to null in LocalLeaderEndPointTest, HighwatermarkPersistenceTest, IsrExpirationTest, ReplicaManagerQuotasTest, OffsetsForLeaderEpochTest (#18344)
PR-18333 - KAFKA-18272: Deprecated protocol api usage should be logged at info level (3.9) (#18333)
PR-18283 - KAFKA-18317 Remove zookeeper.connect from RemoteLogManagerTest (#18283)
PR-18295 - KAFKA-18339: Remove raw unversioned direct SASL protocol (KIP-896) (#18295)
PR-18313 - KAFKA-18272: Deprecated protocol api usage should be logged at info level (#18313)
PR-18282 - KAFKA-18295 Remove deprecated function Partitioner#onNewBatch (#18282)
PR-18317 - KAFKA-18348 Remove the deprecated MockConsumer#setException (#18317)
PR-18324 - KAFKA-18352: Add back DeleteGroups v0, it incorrectly tagged as deprecated (#18324)
PR-18323 - KAFKA-18352: DeleteGroups v0 incorrectly tagged as deprecated (3.9) (#18323)
PR-18250 - KAFKA-18093 Remove deprecated DeleteTopicsResult#values (#18250)
PR-18312 - KAFKA-18343: Use java_pids to implement pids (#18312)
PR-18294 - KAFKA-18338 add log4j.yaml to test-common-api and remove unsed log4j.properties from test-common (#18294)
PR-18306 - KAFKA-18342 Use File.exist instead of File.exists to ensure the Vagrantfile works with Ruby 3.2+ (#18306)
PR-18246 - KAFKA-18290 Remove deprecated methods of FeatureUpdate (#18246)
PR-18255 - KAFKA-18289 Remove deprecated methods of DescribeTopicsResult (#18255)
PR-18265 - KAFKA-18291 Remove deprecated methods of ListConsumerGroupOffsetsOptions (#18265)
PR-18267 - KAFKA-17393: Remove log.message.format.version/message.format.version (KIP-724) (#18267)
PR-18132 - KAFKA-17705: Add Transactions V2 system tests and mark as production ready (#18132)
PR-18291 - KAFKA-18269: Remove deprecated protocol APIs support (KIP-896, KIP-724) (#18291)
PR-18288 - KAFKA-18334: Produce v4-v6 should be undeprecated (#18288)
PR-18262 - KAFKA-18270: FindCoordinator v0 incorrectly tagged as deprecated (#18262)
PR-18221 - KAFKA-18270: SaslHandshake v0 incorrectly tagged as deprecated (#18221)
PR-18249 - KAFKA-13722: code cleanup after deprecated StateStore.init() was removed (#18249)
PR-18285 - KAFKA-18312: Added entityType: topicName to SubscribedTopicNames in ShareGroupHeartbeatRequest.json (#18285)
PR-18204 - KAFKA-18262 Remove DefaultPartitioner and UniformStickyPartitioner (#18204)
PR-18257 - KAFKA-18296 Remove deprecated KafkaBasedLog constructor (#18257)
PR-18238 - KAFKA-12829: Remove old Processor and ProcessorSupplier interfaces (#18238)
PR-18245 - KAFKA-18292 Remove deprecated methods of UpdateFeaturesOptions (#18245)
PR-18154 - KAFKA-12829: Remove deprecated Topology#addProcessor of old Processor API (#18154)
PR-18243 - KAFKA-13722: Refactor Kafka Streams store interfaces (#18243)
PR-18241 - KAFKA-17131: Refactor TimeDefinitions (#18241)
PR-18242 - KAFKA-13722: Refactor SerdeGetter (#18242)
PR-18176 - KAFKA-18227: Ensure v2 partitions are not added to last transaction during upgrade (#18176)
PR-18260 - KAFKA-18294 Remove deprecated SourceTask#commitRecord (#18260)
PR-18211 - KAFKA-18264 Remove NotLeaderForPartitionException (#18211)
PR-18248 - KAFKA-18094 Remove deprecated TopicListing(String, Boolean) (#18248)
PR-18205 - KAFKA-18026: transition KTable#filter impl to use processor wrapper (#18205)
PR-18244 - KAFKA-18293 Remove org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler and org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerValidatorCallbackHandler (#18244)
PR-18234 - KAFKA-17960; PlaintextAdminIntegrationTest.testConsumerGroups fails with CONSUMER group protocol (#18234)
PR-18144 - KAFKA-18200; Handle empty batches in coordinator runtime (#18144)
PR-18206 - KAFKA-17507; WriteTxnMarkers API must not return until markers are written and materialized in group coordinator’s cache (#18168) (#18206)
PR-18180 - KAFKA-18237: Upgrade system tests from using 3.7.1 to 3.7.2 (#18180)
PR-18210 - KAFKA-18259: Documentation for consumer auto.offset.reset contains invalid HTML (#18210)
PR-18207 - KAFKA-18263; Group lock must be acquired when reverting static membership rejoin (#18207)
PR-18166 - KAFKA-18226: Disable CustomQuotaCallbackTest and remove isKRaftTest (#18166)
PR-18192 - KAFKA-18247 Use log4j2 yaml to rewrite the fix of KAFKA-18145 (#18192)
PR-18096 - KAFKA-18014: Add duration based offset reset option for ShareConsumer (#18096)
PR-18194 - KAFKA-18026: KIP-1112, migrate foreign-key joins to use ProcesserSupplier#stores (#18194)
PR-18191 - KAFKA-18246 Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs (#18191)
PR-18155 - KAFKA-18026: supply stores for KTable#mapValues using ProcessorSupplier#stores (#18155)
PR-18089 - KAFKA-18160 Interrupting or waking up onPartitionsAssigned in AsyncConsumer can cause the ConsumerRebalanceListenerCallbackCompletedEvent to be skipped (#18089)
PR-18173 - KAFKA-18234 DumpLogSegments cannot print ConsumerGroupRegularExpression record (#18173)
PR-18184 - KAFKA-18240 Remove nonexistent LOG4J_CONFIG from transactional_message_copier.py (#18184)
PR-17880 - KAFKA-14587: Move AclCommand to tools (#17880)
PR-18182 - KAFKA-18242 The java code in core module is NOT configured with suitable release version (#18182)
PR-17859 - KAFKA-17928: Make remote log manager thread-pool configs dynamic (#17859)
PR-18170 - KAFKA-18223 Add GHA to run report [2/n] (#18170)
PR-18105 - KAFKA-18181 Refactor ShareConsumerTest (#18105)
PR-18168 - KAFKA-17507; WriteTxnMarkers API must not return until markers are written and materialized in group coordinator’s cache (#18168)
PR-17807 - KAFKA-17641; Update Vote RPC with PreVote field (#17807)
PR-18172 - KAFKA-18224: Explicit group protocol setting in streams resetter (#18172)
PR-18113 - KAFKA-18183 replace BytesSerializer with ByteArraySerializer for producer/consumer (#18113)
PR-18134 - KAFKA-18203 Add a section for Java version in intellij idea in README (#18134)
PR-18163 - KAFKA-18228 The MetricsDuringTopicCreationDeletionTest should delete topics to ensure that the metrics are recreated (#18163)
PR-18156 - KAFKA-18218 fix Trogdor system test (#18156)
PR-17373 - KAFKA-9366 Upgrade log4j to log4j2 (#17373)
PR-18127 - KAFKA-18199; Fix size calculation for nullable tagged structs (#18127)
PR-17199 - KAFKA-16143: New JMX metrics for AsyncKafkaConsumer (#17199)
PR-18141 - KAFKA-17750; Extend kafka-consumer-groups command line tool to support new consumer group (part 3) (#18141)
PR-17524 - KIP-1073: Return fenced brokers in DescribeCluster response (#17524)
PR-18145 - KAFKA-18214 TestUtils#waitForCondition does not honor the maxWaitMs (#18145)
PR-18111 - KAFKA-18026: KIP-1112, migrate stream-stream joins to use ProcesserSupplier#stores (#18111)
PR-18149 - KAFKA-18026: KIP-1112 convert StreamToTableNode (#18149)
PR-18137 - KAFKA-16368: Update remote.log.manager.* default thread pool values for KIP-1030 (#18137)
PR-18159 - KAFKA-18219 Use INFO level instead of ERROR after successfully performing an unclean leader election (#18159)
PR-18160 - Set protocol for streams tests (#18160)
PR-18016 - KAFKA-18136: Remove zk migration from code base (#18016)
PR-18014 - KAFKA-18058: Share group state record pruning impl. (#18014)
PR-18048 - KAFKA-18026: KIP-1112, migrate table-table joins to use ProcesserSuppliers#stores (#18048)
PR-18104 - KAFKA-18186 Set options.release to make Intellij configure suitable language level automatically (#18104)
PR-17741 - KAFKA-18215: KIP-891 Connect Multiversioning Support (Configs and Validation changes for Connectors and Converters) (#17741)
PR-18115 - KAFKA-18015: add byDuration auto.offset.reset to Kafka Streams (#18115)
PR-18088 - KAFKA-12829: Remove deprecated KStream.process() for old Processor API (#18088)
PR-18098 - KAFKA-18021: Disabled MirrorCheckpointConnector throws RetriableException on task config generation (#18098)
PR-18143 - KAFKA-17040: Removing exception on further calls to terminated telemetry reporter (#18143)
PR-17973 - KAFKA-18015: Add support for duration based offset reset strategy to Kafka Streams (#17973)
PR-17352 - KAFKA-17030; Unattached voters will fetch from bootstrap servers (#17352)
PR-18138 - KAFKA-17554 disable testFutureCompletionOutsidePoll (#18138)
PR-18109 - KAFKA-18189: CoordinatorRequestManager log message can include incorrect coordinator disconnect time (#18109)
PR-16754 - KAFKA-16437 Upgrade to Jakarta and Jetty 12 (KIP-1032) (#16754)
PR-18036 - KAFKA-18156 VerifiableConsumer should ignore “–session-timeout” when using CONSUMER protocol (#18036)
PR-18095 - KAFKA-18179: Move AsyncOffsetReadFutureHolder to storage module (#18095)
PR-18116 - KAFKA-18188; Admin LeaveGroup should allow removing member using consumer protocol by member id (#18116)
PR-18123 - update test configs (#18123)
PR-18119 - Add null check (#18119)
PR-18079 - regex integration tests (#18079)
PR-18034 - KAFKA-17750: Extend kafka-consumer-groups command line tool to support new consumer group (part 2) (#18034)
PR-18092 - KAFKA-18178 Remove ZkSecurityMigrator (#18092)
PR-18108 - KAFKA-18040; fix for test that ensures produce during follower shutdown (#18108)
PR-17906 - KAFKA-18026: KIP-1112, document new config and update the Streams upgrade guide (#17906)
PR-18114 - KAFKA-18192 generator module should run under java 11 (#18114)
PR-18102 - KAFKA-18184 Remove the unnecessary project path check from build.gradle (#18102)
PR-17843 - KAFKA-18030 Remove old upgrade-system-tests modules (#17843)
PR-17931 - KAFKA-18067: Kafka Streams can leak Producer client under EOS (#17931)
PR-18083 - KAFKA-18174: Subsequent write event completions should be a noop (#18083)
PR-18063 - KAFKA-18164: Clear existing acknowledgements on share session epoch reset. (#18063)
PR-17500 - KAFKA-14619; KRaft validate snapshot id are at batch boundaries (#17500)
PR-17440 - KAFKA-17696 New consumer background operations unaware of metadata errors (#17440)
PR-18046 - KAFKA-18134; Disallow group upgrades when custom assignors are used (#18046)
PR-17882 - KAFKA-16339: [4/4 KStream#flatTransformValues] Remove Deprecated “transformer” methods and classes (#17882)
PR-18093 - KAFKA-18129 Simplifying share partition maybeInitialize code (#18093)
PR-17992 - KAFKA-18118 Fix the incorrect soft link of results/latest (#17992)
PR-17681 - KAFKA-17864: add descriptions to fields in the agreement (#17681)
PR-18081 - KAFKA-17548: Improve group listing integration test (#18081)
PR-16984 - KAFKA-18182: KIP-891 Add VersionRange to Plugins and DelegatingClassLoader APIs (#16984)
PR-18021 - KAFKA-18144 Move the storage exceptions out of the core module (#18021)
PR-17580 - KAFKA-17796: Persist higher leaderEpoch in read state call. (#17580)
PR-18057 - KAFKA-18162 Move LocalLogTest to storage module (#18057)
PR-18058 - KAFKA-18163: Move VerificationGuardTest to storage module (#18058)
PR-17965 - KAFKA-18084 Added usage for rollback state while SharePartition acquires records (#17965)
PR-17698 - KAFKA-14563: RemoveClient-Side AddPartitionsToTxn Requests (#17698)
PR-18020 - KAFKA-17593; [11/11] Update subscription type (#18020)
PR-17815 - KAFKA-17200: Allow the replication of user internal topics (#17815)
PR-17979 - KAFKA-17945, KAFKA-17944: Handling leader epoch error for offset reset APIs (#17979)
PR-18064 - KAFKA-18148 Remove exceptions from method signatures in Persister (#18064)
PR-17706 - KAFKA-17550: DescribeGroups v6 exploitation (#17706)
PR-18045 - KAFKA-18106: Generate LeaderAndIsrUpdates on unclean shutdown (#18045)
PR-18049 - KAFKA-18159 Remove onPartitionsRevoked and onPartitionsAssigned from SinkTask (#18049)
PR-18022 - KAFKA-18140 Remove ZooKeeperMainWithTlsSupportForKafka (#18022)
PR-18053 - KAFKA-18129: SharePartition#maybeInitialize should complete the future outsize the write lock (#18053)
PR-17886 - KAFKA-18052: Decouple the dependency of feature stable version to the metadata version (#17886)
PR-18047 - KAFKA-18026: KIP-1112, migrate stream-table joins to use ProcesserSupplier#stores (#18047)
PR-17980 - KAFKA-18086: Enable propagation of the error message when writing state (#17980)
PR-17984 - KAFKA-18122 : Added support for ShareConsumeBenchWorker (#17984)
PR-17976 - KAFKA-17593; [10/N] Remove resolved regular expressions when unsubscribed (#17976)
PR-18031 - KAFKA-17598; Command line validation tool for RE2J regex (#18031)
PR-18029 - KAFKA-18155 : Fix bug in response handler for ShareAcknowledge (#18029)
PR-17999 - KAFKA-18050 Upgrade the checkstyle version to 10.20.2 (#17999)
PR-17699 - KAFKA-17947: Update currentLag(), pause(), and resume() to update SubscriptionState in background thread (#17699)
PR-18005 - KAFKA-18132 Remove “session.timeout.ms” from connect-distributed.properties to fix connect e2e (#18005)
PR-17796 - KAFKA-17783: Adding listeners to remove share partition on partition changes (#17796)
PR-18038 - KAFKA-17460 Remove downgrade_test.py (#18038)
PR-18024 - KAFKA-18096: Allow join with regex if no matching topics (#18024)
PR-17985 - KAFKA-18025: Rework acquisition lock timeout test (#17985)
PR-17989 - KAFKA-18127 Validate SubscriptionPattern used on v0 HB (#17989)
PR-18025 - KAFKA-18152 add 0.11, 1.0, 1.1, and 2.0 streams dependencies to dockerfile (#18025)
PR-18023 - KAFKA-18145 Fix failed e2e ConnectDistributedTest.test_dynamic_logging (#18023)
PR-18015 - KAFKA-18026: KIP-1112, skip re-registering aggregate stores in StatefulProcessorNode (#18015)
PR-17991 - KAFKA-18101: Merge duplicate assertFutureThrows and assertFutureExceptionTypeEquals (#17991)
PR-18011 - KAFKA-18137: Unloading transaction state incorrectly removes loading partitions (#18011)
PR-17958 - KAFKA-17750 Extend kafka-consumer-groups command line tool to support new consumer group (part 1) (#17958)
PR-17914 - KAFKA-18060 new coordinator does not handle TxnOffsetCommitRequest with empty member id when using CONSUMER group (#17914)
PR-17957 - KAFKA-18084 Added write locks in SharePartition where locks were async calls were being made (#17957)
PR-17756 - KAFKA-17893: Support record keys in the foreignKeyExtractor argument of KTable foreign join (#17756)
PR-18009 - KAFKA-18138: The controller must add all extant brokers to BrokerHeartbeatTracker when activating (#18009)
PR-17920 - KAFKA-18047: Add org.apache.kafka.automatic.config.providers to System Properties section (#17920)
PR-18003 - KAFKA-18095; Allow a member to join without subscription under new consumer protocol (#18003)
PR-17929 - KAFKA-18026: migrate KStream and KTable aggregates to use ProcesserSupplier#stores (#17929)
PR-18008 - KAFKA-18013: Add integration test for duration based reset strategy in KafkaConsumer (#18008)
PR-17990 - KAFKA-18124 Remove zk migration from RaftManagerTest, BrokerLifecycleManagerTest, KafkaConfigTest, and ReplicaManagerTest (#17990)
PR-18002 - KAFKA-17610 Drop alterConfigs (#18002)
PR-10967 - KAFKA-12770 introduce checkstyleVersion gradle property (for overriding CheckStyle project-defined dependency version) (#10967)
PR-17996 - KAFKA-18128 Fix failed test MetadataSchemaCheckerToolTest.testVerifyEvolutionGit in PR (#17996)
PR-18001 - KAFKA-18130 Remove kafka.utils.VersionInfo (#18001)
PR-15304 - KAFKA-16181: Use incrementalAlterConfigs when updating broker configs by kafka-configs.sh (#15304)
PR-17552 - KAFKA-16617 Add KRaft info for the advertised.listeners doc description (#17552)
PR-17972 - KAFKA-18013: Add support for duration based offset reset strategy to Kafka Consumer (#17972)
PR-17964 - KAFKA-15561 [5/N]: Integration tests for new subscribe API with Re2J pattern (#17964)
PR-16899 - KAFKA-17338 ConsumerConfig should prevent using partition assignors with CONSUMER group protocol (#16899)
PR-17975 - KAFKA-18090: Add ShareMemberDescription and Assignment (#17975)
PR-17928 - KAFKA-17997 Remove deprecated config log.message.timestamp.difference.max.ms (#17928)
PR-17740 - KAFKA-17979 Change [pytest] to [tool:pytest] in setup.cfg file (#17740)
PR-17970 - KAFKA-18100 Using block suppresses all errors (#17970)
PR-17971 - KAFKA-18109 Fix failed SaslClientsWithInvalidCredentialsTest in tools module (#17971)
PR-17903 - KAFKA-18026: migrate KTableSource to use ProcesserSupplier#stores (#17903)
PR-17948 - KAFKA-18097 Upgrade readme to include min JDK changes (#17948)
PR-17955 - KAFKA-18098 add kraft support to testReplicaPlacementAllServers and testReplicaPlacementPartialServers (#17955)
PR-17953 - KAFKA-17010 Remove DescribeLogDirsResponse#LogDirInfo, DescribeLogDirsResponse#ReplicaInfo, and DescribeLogDirsResult#all (#17953)
PR-17962 - KAFKA-15561 [4/N]: MockConsumer support for SubscriptionPattern (#17962)
PR-17954 - KAFKA-18100 Using block suppresses all errors (#17954)
PR-17961 - KAFKA-17593; [9/N] Mark ConsumerGroupHeartbeat API v1 as stable (#17961)
PR-17951 - KAFKA-15561 [3/N]: Client support for SubscriptionPattern in HB (#17951)
PR-17934 - KAFKA-18081 Remove isKRaftTest from the kraft-only tests (#17934)
PR-17844 - KAFKA-18012: Update the Scram configuration section for KRaft (#17844)
PR-17904 - KAFKA-12844: clean up TaskId (#17904)
PR-17867 - KAFKA-18062: use feature version to enable ELR (#17867)
PR-17879 - KAFKA-18049: Upgrade the caffeine version to 3.1.1 (#17879)
PR-17864 - KAFKA-17593; [8/N] Resolve regular expressions (#17864)
PR-17736 - KAFKA-17569 Rewrite TestLinearWriteSpeed by Java (#17736)
PR-17522 - KAFKA-17811 Separate modules to use different JDKs (#17522)
PR-17909 - KAFKA-18056: Fixed bug in handling commitAsync responses (#17909)
PR-17932 - KAFKA-18083 ClusterInstance custom controllerListener not work (#17932)
PR-17918 - KAFKA-15561 [2/N]: Background event and subscription state changes for RE2J pattern (#17918)
PR-17927 - KAFKA-18080 Replace DelayedItem by Long type (#17927)
PR-17916 - KAFKA-17990: Deflake testShareAutoOffsetResetDefaultValue (#17916)
PR-17940 - KAFKA-17544: Add log message for early access use of KafkaShareConsumer (#17940)
PR-17849 - KAFKA-17898: Refine Epoch Bumping Logic (#17849)
PR-17783 - KAFKA-17869: Adding tests to ensure KIP-1076 doesn’t interfere producer metrics[2/3] (#17783)
PR-17919 - KAFKA-17299: add unit tests for previous fix (#17919)
PR-17899 - KAFKA-17299: Fix Kafka Streams consumer hang issue (#17899)
PR-17939 - KAFKA-18085: Abort inflight requests on existing connections while rebootstrapping (#17939)
PR-17933 - Fix long running RangeQueryIntegrationTest. (#17933)
PR-17912 - KAFKA-17956 Remove Admin.listShareGroups (#17912)
PR-17923 - KAFKA-18077 Remove deprecated JmxReporter(String) (#17923)
PR-17858 - KAFKA-18013: Add AutoOffsetResetStrategy internal class (#17858)
PR-17876 - KAFKA-18045 Add 0.11, 1.0, 1.1, and 2.0 back to streams_upgrade_test.py (#17876)
PR-17917 - KAFKA-18071: Avoid event to refresh regex if no pattern subscription (#17917)
PR-17925 - KAFKA-18079 consumer-config does not work with console-share-consumer (#17925)
PR-17924 - KAFKA-18078 Fix failed MetricsTest.testJMXFilter (#17924)
PR-17926 - KAFKA-18075 Prevent ClusterInstance default producer and consumer initialization with empty configs (#17926)
PR-17892 - KAFKA-18026: KIP-1112, ProcessorWrapper API with PAPI and partial DSL implementation (#17892)
PR-17922 - KAFKA-18076 Remove isZkMigrationTest and related code (#17922)
PR-17857 - KAFKA-18037 Remove deprecated methods from EmbeddedConnect and EmbeddedConnectCluster (#17857)
PR-17883 - KAFKA-18051: Disallow creating ACLs with principals that do not contain a colon (#17883)
PR-17266 - KAFKA-16339: [3/4 KStream#transformValues] Remove Deprecated “transformer” methods and classes (#17266)
PR-17897 - KAFKA-15561 [1/N]: Introduce new subscribe api for RE2J regex (#17897)
PR-17907 - KAFKA-18059 kafka-metadata-quorum.sh add-controller subcommand can’t recognize argument –config (#17907)
PR-17865 - KAFKA-12690 Remove deprecated Producer#sendOffsetsToTransaction (#17865)
PR-17847 - KAFKA-17917: Convert Kafka core system tests to use KRaft (#17847)
PR-17898 - KAFKA-18063: SnapshotRegistry should not leak memory (#17898)
PR-17889 - KAFKA-18038: fix flakey test StreamThreadTest.shouldLogAndRecordSkippedRecordsForInvalidTimestamps (#17889)
PR-17781 - KAFKA-17869: Adding tests to ensure KIP-1076 doesn’t interfere with consumer metrics[1/3] (#17781)
PR-17403 - KAFKA-17640 Document Java 23 support and include release note (#17403)
PR-17412 - KAFKA-15387: Remove Connect’s deprecated task configurations endpoint (#17412)
PR-17884 - KAFKA-16041: Replace Afterburn module with Blackbird (#17884)
PR-17711 - KAFKA-17850: fix leaking internal exception in state manager (#17711)
PR-17869 - KAFKA-18041: Update key for storing global consumer instance id for consistency (#17869)
PR-17842 - KAFKA-18027: MINOR: Correct DelayedOperationPurgatory code around adding of an already completed operation (#17842)
PR-17525 - KAFKA-17721 Enable to configure listener name and protocol for controller (#17525)
PR-17853 - KAFKA-17733: Protocol upgrade should allow empty member assignment in group conversion (#17853)
PR-17763 - KAFKA-17949: Introduce GroupState and replace ShareGroupState (#17763)
PR-17823 - KAFKA-17593; [7/N] Introduce CoordinatorExecutor (#17823)
PR-17725 - KAFKA-17767 Automatically quarantine new tests [5/n] (#17725)
PR-17713 - KAFKA-17954: Error getting oldest-iterator-open-since-ms from JMX (#17713)
PR-17820 - KAFKA-17561: KIP-1091 add operator metrics (#17820)
PR-17824 - KAFKA-18016: Modified handling of piggyback acknowledgements in ShareConsumeRequestManager. (#17824)
PR-17774 - KAFKA-14934 KafkaClusterTestKit makes FaultHandler accessible (#17774)
PR-17840 - KAFKA-18003: Add test to make sure Admin#deleteRecords can handle the corrupted records (#17840)
PR-17712 - KAFKA-17910 Create integration tests for Admin.listGroups and Admin.describeClassicGroups (#17712)
PR-17367 - KAFKA-17663 Add metadata caching in PartitionLeaderStrategy (#17367)
PR-17717 - KAFKA-17927 Disallow users to configure max.in.flight.requests.per.connection bigger than 5 (#17717)
PR-17822 - KAFKA-18019: Make INVALID_PRODUCER_ID_MAPPING a fatal error (#17822)
PR-17805 - KAFKA-18017: Fix call order for HB error and group manager (#17805)
PR-17811 - KAFKA-17987 Remove ZooKeeper related windows scripts (#17811)
PR-17838 - KAFKA-18029 remove the kraft.version=1 from kafka.py (#17838)
PR-17839 - KAFKA-18029 Fix quorum_reconfiguration_test.py (#17839)
PR-17825 - KAFKA-18022: fetchOffsetMetadata handling for minBytes estimation in both common/uncommon cases of share fetch (#17825)
PR-17777 - KAFKA-16460: New consumer times out consuming records in multiple consumer_test.py system tests (#17777)
PR-17739 - KAFKA-17948: Potential issue during tryComplete and onComplete simultaneous calls to access global variables (#17739)
PR-17542 - KAFKA-17791: Dockerfile should use requirements.txt for dependencies (#17542)
PR-17516 - KAFKA-17648: AsyncKafkaConsumer#unsubscribe and #close swallow TopicAuthorizationException and GroupAuthorizationException (#17516)
PR-17800 - KAFKA-18006: Add 3.9.0 to end-to-end test (streams) (#17800)
PR-17817 - KAFKA-17994 Checked exceptions are not handled (#17817)
PR-17798 - KAFKA-17977 Remove new_consumer from E2E (#17798)
PR-17797 - KAFKA-18006 Add 3.9.0 to end-to-end test (core, client) (#17797)
PR-17709 - KAFKA-17510: Exception handling and purgatory completion on initialization delay (#17709)
PR-17625 - KAFKA-17888 Upgrade ZooKeeper version from 3.4.9 to 3.5.7 to avoid ZOOKEEPER-3779, which can’t run under JDK 11. (#17625)
PR-17794 - KAFKA-17995: Fix errors in remote segment cleanup when retention.ms is large (#17794)
PR-17802 - KAFKA-17992 Remove getUnderlying and isKRaftTest from ClusterInstance (#17802)
PR-17806 - KAFKA-18009: Remove extra public constructor for KafkaShareConsumer (#17806)
PR-16686 - KAFKA-16985: Ensure consumer attempts to send leave request on close even if interrupted (#16686)
PR-17791 - KAFKA-17593; [6/N] Add new record to GroupCoordinatorRecordSerde (#17791)
PR-17799 - Update javadoc on split to mention first matching (#17799)
PR-17750 - KAFKA-17593; [5/N] Include resolved regular expressions into target assignment computation (#17750)
PR-17720 - KAFKA-17885: Enable clients to rebootstrap based on timeout or error code (KIP-1102) (#17720)
PR-17790 - KAFKA-18004 Use version 3.8 to run the ZooKeeper service for end-to-end tests (#17790)
PR-17768 - KAFKA-17987 Remove assorted ZK-related files (#17768)
PR-16705 - KAFKA-17109: Reduce log message load for failed locking (#16705)
PR-17666 - KAFKA-17922 add helper to ClusterInstance to create client component (#17666)
PR-17772 - KAFKA-17991: Added timed calls for future.get in persister. (#17772)
PR-17735 - KAFKA-16780: Document the new RemoteLogMetadataManager#nextSegmentWithTxnIndex API in upgrade notes. (#17735)
PR-17737 - KAFKA-17980: Introduce isReady API in RemoteLogMetadataManager (#17737)
PR-17758 - KAFKA-17985: Set share.auto.offset.reset to earliest in ShareRoundTripWorker (#17758)
PR-17714 - KAFKA-17744: Improve state updater logs when restorating state (#17714)
PR-17778 - KAFKA-17978: Fix invalid topology on Task assignment (#17778)
PR-17620 - KAFKA-17632: Fix RoundRobinPartitioner for even partition counts (#17620)
PR-17749 - KAFKA-17314 Fix the typo: maxlifeTimeMs (#17749)
PR-17754 - KAFKA-17975 Remove ControllerQuorumVotersFutureManager (#17754)
9e01a921 - KAFKA-15722: Add KRaft support in RackAwareAutoTopicCreationTest
PR-17507 - KAFKA-17787: Removed –zookeeper option and logic from ConfigCommand (#17507)
PR-17573 - KAFKA-16726: Added share.auto.offset.reset dynamic config for share groups (#17573)
PR-17243 - KAFKA-17583 Improve the ConfigCommand documentation to show how to set key=[val1,val2] (#17243)
PR-17734 - KAFKA-17974 Upgrade gradle from 8.10 to 8.10.2 (#17734)
PR-17673 - KAFKA-17923 Remove old kafka version from e2e (#17673)
6ea2ed3d - KAFKA-17801: RemoteLogManager may compute inaccurate upperBoundOffset for aborted txns (#17676) (#1 7733)
PR-17670 - KAFKA-17925 Convert Kafka Client integration tests to use KRaft (#17670)
PR-17710 - KAFKA-17872: Update consumed offsets on records with invalid timestamp (#17710)
PR-17730 - KAFKA-15549 Bump swagger dependency version from 2.2.8 to 2.2.25 (#17730)
PR-17579 - KAFKA-17837 Rewrite DeleteTopicTest (#17579)
PR-17722 - KAFKA-17970 Moving some share purgatory classes from core to share module (#17722)
PR-17249 - KAFKA-17570 Rewrite StressTestLog by Java (#17249)
PR-17723 - KAFKA-17969 Fix StorageToolTest for 3.9 (#17723)
PR-17676 - KAFKA-17801: RemoteLogManager may compute inaccurate upperBoundOffset for aborted txns (#17676)
PR-17702 - rebase to fix merge conflict (#17702)
PR-17719 - KAFKA-17926 Improve the documentation explaining why max.in.flight.requests.per.connection should not exceed 5 (#17719)
PR-17660 - KAFKA-17914: Update string ref with SharePartitionKey. (#17660)
PR-17659 - KAFKA-16780: Txn consumer exerts pressure on remote storage when collecting aborted txns (#17659)
PR-17636 - KAFKA-17890: Move DelayedOperationPurgatory to server-common (#17636)
PR-17694 - KAFKA-17593; [4/N] Introduce ConsumerGroupRegularExpression record & related bookkeeping in ConsumerGroup (#17694)
PR-17245 - KAFKA-16339: [2/4 KStream#flatTransform] Remove Deprecated “transformer” methods and classes (#17245)
PR-17657 - KAFKA-17913 Fix KRaft controller count recommendations (#17657)
PR-17567 - KAFKA-17576 Fix all references to kraft/server.properties to use reconfig-server.properties (#17567)
PR-17630 - KAFKA-17248 - KIP 1076 Add process-id to get carried to telemetry results (#17630)
PR-17539 - KAFKA-17743: Add minBytes implementation to DelayedShareFetch (#17539)
PR-17150 - KAFKA-17480: New consumer commit all consumed should retrieve offsets in background thread (#17150)
PR-17692 - KAFKA-17933: Added round trip trogdor workload for share consumer. (#17692)
PR-17691 - KIP-16331: Remove EOS-v1 from StreamsConfigUtils (#17691)
PR-17708 - Update docker_scan.yml for 3.9.0 (#17708)
PR-17686 - KAFKA-17635: Ensure only committed offsets are returned for purging (#17686)
cc53a632 - Bump version to 3.9.0
PR-17680 - KAFKA-17896: Admin.describeClassicGroups (#17680)
PR-17655 - KAFKA-17911: Fix handling of env variables in KafkaDockerWrapper (#17655)
PR-17697 - KAFKA-17924: Remove bufferpool-wait-time-total, io-waittime-total, and iotime-total (#17697)
PR-16988 - KAFKA-12827 Remove Deprecated method KafkaStreams#setUncaughtExceptionHandler (#16988)
PR-17198 - KAFKA-16339: [1/4 KStream#transform] Remove Deprecated “transformer” methods and classes (#17198)
PR-17679 - KAFKA-17931 Revise the specifying-test-retries section in README (#17679)
PR-17682 - KAFKA-17936 Refactor SslTransportLayerTest#testDsaKeyPair to avoid skip test (#17682)
PR-17689 - KAFKA-17916: removing ZK from connect ducktape tests (#17689)
PR-17688 - Fix TransactionStateManager handling of empty batch when loading transaction metadata (#17688)
PR-17021 - KAFKA-17248 - KIP 1076 implementation (#17021)
PR-17275 - KAFKA-17609:[1/4] Changes needed to convert system tests to use KRaft and remove ZK (#17275)
PR-17559 - KAFKA-16816: Remove unneeded FencedInstanceId support on commit path for new consumer (#17559)
PR-17619 - KAFKA-17877; Only call once maybeSendResponseCallback for each marker (#17619)
PR-17537 - KAFKA-17819 : Handle piggyback acknowledgements when subscription changes in ShareConsumeRequestManager. (#17537)
PR-17594 - KAFKA-17857 Move AbstractResetIntegrationTest and subclasses to tools (#17594)
PR-17582 - KAFKA-16964 Integration tests for adding and removing voters (#17582)
PR-17683 - Removed Set.of usage (#17683)
PR-17638 - KAFKA-17625: Removing explicit ZK test parameterizations (#17638)
PR-1510 - Modified Set.of usage in ReplicationControlManagerTest.java to resolve build failures.
PR-17672 - KAFKA-17906 Remove redundant sourceSets from build.gradle (#17672)
PR-17661 - KAFKA-17767 Parse quarantined tests and display them [4/n] (#17661)
PR-17653 - KAFKA-17593; [3/N] Track the number of subscribed members per regular expression in ConsumerGroup (#17653)
PR-17651 - KAFKA-17593; [2/N] Update request validation & validate regex (#17651)
PR-17658 - KAFKA-17919 enable back the failing testShareGroups test (#17658)
PR-17645 - KAFKA-17463 add retry in Persister for NOT_COORDINATOR error (#17645)
PR-17652 - KAFKA-17908 Tweak log messages in group metadata manager (#17652)
PR-17618 - KAFKA-17882 improve the document about “default value” of tagged structure field (#17618)
PR-17665 - KAFKA-17909 Remove zkBroker from ConsumerGroupHeartbeatRequest and ConsumerGroupDescribeRequest (#17665)
PR-17674 - KAFKA-17795 Fix the file path of suppressions.xml to run build on windows (#17674)
PR-17613 - KAFKA-17814 Use final declaration to replace the suppression this-escape (#17613)
PR-17626 - KAFKA-17546 Admin.listGroups and kafka-groups.sh (#17626)
PR-17528 - KAFKA-17803: LogSegment#read should return the base offset of the batch that contains startOffset rather than startOffset (#17528)
PR-17402 - KAFKA-14562 [2/3]: Implement epoch bump after every transaction (KIP-890) (#17402)
PR-17654 - KAFKA-17767 Load test catalog data [3/n] (#17654)
PR-17615 - KAFKA-17880 Move integration test from streams module to streams/integration-tests module (#17615)
PR-17656 - KAFKA-17912 Align string representations of SharePartitionKey (#17656)
PR-17604 - [KAFKA-17870] Fail CreateTopicsRequest if total number of partitions exceeds 10k (#17604)
PR-17549 - KAFKA-17116 New consumer may not send effective leave group if member ID received after close (#17549)
PR-17637 - KAFKA-17899 Add more unit tests for NetworkReceive (#17637)
PR-17648 - KAFKA-17905 Remove the specified type of using lambda for BaseFunction (#17648)
PR-17644 - KAFKA-17903 Remove KafkaFuture#Function and KafkaFuture#thenApply (#17644)
PR-16842 - KAFKA-17002: Integrated partition leader epoch for Persister APIs (KIP-932) (#16842)
PR-17569 - KAFKA-17726: New consumer subscribe/subscribeFromPattern in background thread (#17569)
PR-17603 - KAFKA-17609 Migrate broker compatibility test from ZK to KRaft (#17603)
PR-17562 - KAFKA-17835 Move ProducerIdManager and RPCProducerIdManager to transaction-coordinator module (#17562)
PR-17627 - KAFKA-17767 Store the test catalog in Git [2/n] (2nd attempt) (#17627)
PR-17321 - KAFKA-17609:[2/4]Convert system tests to kraft part 2 (#17321)
PR-17327 - KAFKA-17609:[3/4]Convert system tests to kraft part 3 (#17327)
PR-17328 - KAFKA-17609:[4/4]Convert system tests to kraft part 4 (#17328)
PR-17634 - KAFKA-17593; [1/N] Introduce re2j dependency (#17634)
PR-17605 - KAFKA-17873: Add description to all packages in the public API (#17605)
PR-17609 - KAFKA-17840 Move ReplicationQuotaManager, ClientRequestQuotaManager and QuotaFactory to server module (#17609)
PR-17622 - KAFKA-17867 Consider using zero-copy for PushTelemetryRequest (#17622)
PR-16922 - KAFKA-17411: Create local state Standbys on start (#16922)
PR-17616 - KAFKA-17128 Make node.id immutable after removing zookeeper migration (#17616)
PR-17623 - Update docker_scan.yml for 3.8.1 (#17623)
PR-17600 - KAFKA-17875: Align KRaft controller count recommendations (#17600)
PR-17091 - KAFKA-15344: Streams task should cache consumer nextOffsets (#17091)
PR-17035 - KAFKA-17439: Make polling for new records an explicit action/event in the new consumer (#17035)
PR-17270 - KAFKA-17329: DefaultStatePersister implementation (#17270)
PR-17502 - KAFKA-17793: Improve kcontroller robustness against long delays (#17502)
PR-17587 - KAFKA-14483 Move LocalLog to storage module (#17587)
PR-17602 - KAFKA-17878 Move ActionQueue to server module (#17602)
PR-17612 - KAFKA-17883 Fix jvm error caused by UseParNewGC when running old kafka client in e2e (#17612)
PR-17599 - KAFKA-17874: Fix the KRaft metric names in the documentation (#17599)
PR-17606 - KAFKA-17879 test_performance_services.py should use DEV version to run kafka service (#17606)
PR-17610 - KAFKA-17881 Apply the minJavaVersion to test code (#17610)
PR-17583 - KAFKA-17848: Fixing share purgatory request and locks handling (#17583)
PR-17597 - KAFKA-17868: Do not ignore –feature flag in kafka-storage.sh (#17597)
PR-16965 - KAFKA-16564 Apply Xlint to java code in core module (#16965)
PR-17592 - KAFKA-17863: share consumer max poll records soft limit (#17592)
PR-17089 - KAFKA-16845 Migrate ReplicationQuotasTestRig to new test infra (#17089)
PR-17578 - KAFKA-17847 Avoid the extra bytes copy when compressing telemetry payload (#17578)
PR-17586 - KAFKA-17854 Improve tests for ReadOnlyWindowStoreStub#fetch and #backwardFetch (#17586)
PR-17225 - KAFKA-17574 Allow overriding TestKitNodes baseDirectory (#17225)
PR-17570 - KAFKA-17846 ClientTelemetryReporter does not log trace-level message (#17570)
PR-1498 - [MINOR]: Fix version check in util.py
PR-1497 - [MINOR]: Fix version check in util.py
PR-17588 - KAFKA-17860 Remove log4j-appender module (#17588)
PR-17038 - KAFKA-17233: MirrorCheckpointConnector should use batched listConsumerGroupOffsets (#17038)
PR-17322 - KAFKA-17774: Adding capability to handle max fetch records in Share Fetch (KIP-932) (#17322)
PR-17246 - KAFKA-17568 Rewrite TestPurgatoryPerformance by Java (#17246)
PR-17424 - KAFKA-17614: Remove AclAuthorizer (#17424)
PR-17414 - KAFKA-17600: Add nextOffsets to the ConsumerRecords (#17414)
PR-17577 - KAFKA-17852 Add help message to the –ignore-formatted flag of StorageTool (#17577)
PR-17201 - KAFKA-17526 make ConfigCommandIntegrationTest.java test use correct arguments in testing alias (#17201)
PR-17519 - KAFKA-17813: Moving broker endpoint class and common server connection id (#17519)
PR-17556 - KAFKA-17839 DescribeConsumerGroupTest doesn’t really test different arguments (#17556)
PR-17566 - KAFKA-17844: Complete share fetch request on exception (#17566)
PR-17503 - KAFKA-17272 [2/2]: System tests for protocol migration (#17503)
PR-17521 - KAFKa-16331: remove EOSv1 support for getting clientInstanceIds (#17521)
PR-17504 - KAFKA-17794: Add some formatting safeguards for KIP-853 (#17504)
PR-17499 - KAFKA-17031: Make RLM thread pool configurations public and fix default handling (#17499)
PR-17534 - KAFKA-17545: Removing process fetch queue (#17534)
PR-17557 - KAFKA-17841 Use placeholders instead of string concatenation in logs (#17557)
PR-17409 - KAFKA-17639 Add Java 23 to CI build matrix (#17409)
PR-17550 - KAFKA-17818 add log4j.properties to test-common and test-common-api (#17550)
PR-17553 - KAFKA-17476 Delete kafka.common.OffsetAndMetadata (#17553)
57abfc24 - KAFKA-17838 Move the log4j.properties from resources/test to resources(#17551)
PR-17505 - KAKFA-17173 move quota config params from KafkaConfig to QuotaConfig (#17505)
PR-17543 - KAFKA-17832 Remove all EnabledForJreRange (#17543)
PR-17535 - KAFKA-17817 Remove cache from FetchRequest#fetchData (#17535)
PR-17536 - KAFKA-17827 cleanup the mockit version (#17536)
PR-17492 - KAFKA-17766: Fixing deadlock in TopicBasedRemoteLogMetadataManager (#17492)
PR-17475 - KAFKA-17099: Print the origin processor node in logs when a processing exception occurs (#17475)
PR-17435 - KAFKA-17740 Update Readme and documentation (#17435)
PR-17523 - KAFKA-17816 Add testRuntimeOnly runtimeTestLibs to test-common-api module (#17523)
8a1a5448 - Bump commonsIo to version 2.16.0 in master
PR-17437 - KAFKA-17742: Move DelayedShareFetchPurgatory declaration to ReplicaManager (#17437)
PR-17315 - KAFKA-17558: Remove parameterization from streams integration tests (#17315)
PR-17474 - KAFKA-17778: Add listener to remove client instances on connection disconnect (#17474)
PR-17512 - KAFKA-17802 Update Bouncy castle from 1.75 to 1.78.1 (#17512)
PR-17520 - KAFKA-17812 upgrade base image of e2e from JDK 11 to JDK 17 (#17520)
PR-17418 - KAFKA-17724 Move SubscriptionState changes to background thread (#17418)
PR-17385 - KAFKA-17710; Rework uniform heterogeneous assignor to improve perf (#17385)
PR-17484 - KAFKA-17677 Remove atomicGetOrUpdate (#17484)
PR-17397 - KAFKA-17767 Extract test catalog from JUnit output [1/n] (#17397)
PR-17473 - KAFKA-17776 Capability for connection disconnect listeners in socket server (#17473)
PR-17354 - KAFKA-17683 Remove Zookeeper from READMEs in 4.0 (#17354)
PR-17518 - KAFKA-17728 Add missing config replica-directory-id to raft README (#17518)
PR-16824 - KAFKA-17256 KRAFT should honor the listener name and security protocol from ClusterConfig (#16824)
PR-17513 - KAFKA-17805: Deprecate named topologies in Kafka Streams (#17513)
PR-17422 - KAFKA-17248: Override admin client to push metrics true, test for case where streams metrics [4/N] (#17422)
PR-17441 - KAFKA-17741 Cleanup code base for JDK 11 (#17441)
PR-17480 - KAFKA-17781 add psutil to e2e dockerfile and upgrade ducktape version (#17480)
PR-17483 - KAFKA-17773 Upgrade spotbug to work under java 23 (#17483)
PR-17411 - KAFKA-17536; Ensure clear error message when new consumer used with incompatible cluster (#17411)
5989c2b1 - Revert “KAFKA-17520 align the low bound of ducktape version (#17481)”
71839deb - Ignore failing quota_test
PR-17487 - KAFKA-15859: Complete delayed RemoteListOffsets requests when replica moves away from broker (#17487)
PR-17501 - KAFKA-17790: Document that control.plane.listener should be removed before ZK migration is finished (#17501)
796ce212 - KAFKA-17788: During ZK migration, always include control.plane.listener.name in advertisedBrokerListeners
PR-1438 - disable flakey test
PR-17450 - KAFKA-17756: Added dynamic share group configs share.heartbeat.interval.ms and share.session.timeout.ms (#17450)
PR-17467 - KAFKA-17633: Add share group record formatter and parser. (#17467)
PR-17497 - KAFKA-17748 Remove scala-java8-compat (#17497)
PR-17456 - KAFKA-17693 Remove testEarliestLocalTimestampVersion and testCheckLatestTieredTimestampVersion (#17456)
PR-17481 - KAFKA-17520 align the low bound of ducktape version (#17481)
PR-16964 - KAFKA-17374 add bootstrap.controller to kafka-reassign-partitions.sh (#16964)
PR-17479 - KAFKA-17765 Remove TestUtils.toSet (#17479)
PR-17451 - KAFKA-17746 Replace JavaConverters with CollectionConverters (#17451)
PR-17468 - KAFKA-17763 Remove Utils.covariantCast and use var for type inference (#17468)
PR-17439 - KAFKA-17722 Fix “this-escape” compiler warnings (BrokerTopicMetrics) for JDK 23 (#17439)
PR-17442 - KAFKA-17199 Add UT for TransactionLogConfig and TransactionStateManagerConfig (#17442)
PR-17458 - KAFKA-17717 Remove ConfigUtils#translateDeprecatedConfigs and tests (#17458)
PR-17417 - KAFKA-17723 Fix “this-escape” compiler warnings (MultiThreadedEventProcessor and DistributedHerder) for JDK 23 (#17417)
PR-17460 - KAFKA-17759 Remove Utils.mkSet (#17460)
PR-17466 - KAFKA-17772 Remove inControlledShutdownBrokers(Set<Integer>) and unfenceBrokers(Set<Integer>) from ReplicationControlManagerTest (#17466)
PR-17452 - KAFKA-17764 Remove unnecessary ignorable annotations (#17452)
PR-17461 - KAFKA-17193: Pin all external GitHub Actions to the specific git hash (#16960) (#17461)
PR-17398 - KAFKA-17713: Don’t generate snapshot when published metadata is not batch aligned (#17398)
44f15cc2 - KAFKA-17749: Fix Throttler metrics name
PR-17283 - KAFKA-17620: Simplifying share partition acquire API (kip-932) (#17283)
PR-16387 - KAFKA-16972 Move BrokerTopicMetrics to org.apache.kafka.storage.log.metrics (#16387)
PR-17431 - KAFKA-17731: Removed timed waiting signal for client telemetry close (#17431)
PR-17430 - KAFKA-17749: Fix Throttler metrics name (#17430)
PR-17446 - KAFKA-17383; Update upgrade notes about removal of offsets.commit.required.acks (#17446)
PR-17413 - KAFKA-17534: Add configuration to disable the heartbeats topic replication (#17413)
PR-17426 - KAFKA-17739 Clean up build.gradle to adopt the minimum Java version as 11 (#17426)
PR-17331 - KAFKA-17532-2: Moved ShareGroupConfig and added share.record.lock.duration.ms to dynamic configs (#17331)
PR-17406 - KAFKA-17387 Remove broker-list in VerifiableConsumer (#17406)
PR-17432 - KAFKA-17738 upgrade base image from jdk8 to jdk11 (#17432)
PR-17427 - KAFKA-17737 E2E tests need to drop Kafka versions prior to 1.0.0 (#17427)
PR-17436 - KAFKA-17753: Update protobuf and commons-io dependencies (#17436)
PR-17434 - KAFKA-17751; fix pollTimeout calculation in pollFollowerAsVoter (#17434)
PR-17380 - KAFKA-17703: Moved DelayedActionsQueue outside DelayedShareFetch (#17380)
PR-17423 - KAFKA-16896 upgrade spotless version after we drop JDK8 (#17423)
PR-16881 - KAFKA-17005; Online protocol migration integration tests (#16881)
PR-17415 - KAFKA-17729: Remove ZK from AuthorizerBenchmark, CheckpointBench and PartitionCreationBench (#17415)
PR-17420 - KAFKA-14705 Remove deprecated classes and options in tools (#17420)
PR-17408 - KAFKA-17655 add example of changing the e2e image name (#17408)
PR-17410 - KAFKA-17720 Remove zookeeper_migration_test.py and migration-related functions in kafka.py (#17410)
PR-17421 - KAFKA-17735: release.py must not use home.apache.org (#17421)
PR-17344 - KAFKA-16331: Remove task producers from Kafka Streams (#17344)
PR-17230 - KAFKA-17505: New consumer seekToBeginning/End should run in background thread (#17230)
8ebb9d80 - Revert “MINOR: Ensure CI runs on weekends (#17396)”
PR-17368 - KAFKA-15908: Remove deprecated Consumer.poll(long timeout) (#17368)
PR-17009 - KAFKA-17287: Added integration tests for ShareConsumer (#17009)
PR-17360 - KAFKA-14158: Remove auto.include.jmx.reporter configuration (#17360)
PR-17400 - KAFKA-17714 Fix StorageToolTest.scala to compile under Scala 2.12 (#17400)
PR-17224 - KAFKA-17385 Remove authorizer, authorizer-properties, zk-tls-config-file in AclCommand (#17224)
PR-17338 - KAFKA-17624 Remove the E2E uses of accessing ACLs from zk (#17338)
PR-17330 - KAFKA-16331: Remove KafkaClientSupplier from unit tests (#17330)
PR-17377 - KAFKA-17248: Add reporter for getting client metrics into telemetry pipeline and test [3/N] (#17377)
PR-17395 - KAFKA-17709: Remove unused retry_zinc script (#17395)
PR-16770 - KAFKA-17146 Include note to remove migration znode (#16770)
PR-17379 - MINRO: fix stream-stream-join semantic example from 10s window to 15s (#17379)
PR-17392 - KAFKA-17711: Minor cleanup changes in ShareConsumeRequestManager (#17392)
PR-17386 - KAFKA-14705: Remove redirections and unused tools (#17386)
PR-17387 - KAFKA-14705: Move topic filters to tools module (#17387)
PR-17383 - KAFKA-17707 Remove zk from BaseConsumerTest (#17383)
PR-17157 - KAFKA-14577: Move ConsoleProducer to tools module (#17157)
PR-17306 - KAFKA-17317; Validate and maybe trigger downgrade after static member replacement (#17306)
PR-17281 - KAFKA-17618; group consumer heartbeat interval should be less than session timeout (#17281)
PR-17228 - KAFKA-17564 Move BrokerFeatures to server module (#17228)
PR-17332 - KAFKA-17664: Added check before sending background event after ShareAcknowledge (#17332)
PR-17364 - KAFKA-17695 cleanup org.apache.kafka.common.test.TestUtils (#17364)
PR-17202 - KAFKA-17529 Remove blacklist from MM2 (#17202)
PR-17372 - KAFKA-17692 Remove KafkaServer references from IntegrationTestUtils (#17372)
PR-17026 - KAFKA-17415 Avoid overflow of expired timestamp (#17026)
PR-17313 - KAFKA-12895 Drop support for Scala 2.12 in Kafka 4.0 (#17313)
PR-17329 - KAFKA-17672 Run quarantined tests separately (#17329)
PR-17378 - KAFKA-17706 Allow all imports for test-common and test-common-api (#17378)
PR-17376 - KAFKA-17248: Add reporter for adding thread metrics to telemetry pipeline and a test [2/N] (#17376)
PR-17260 - KAFKA-17542: Automatically label small PRs (#17260)
PR-17362 - KAFKA-16308 [4/4]: Add release-version flag to upgrade and downgrade commands (#17362)
PR-17375 - KAFKA-17248: KIP-1076 add admin client test helper [1/N] (#17375)
PR-17177 - KAFKA-17509: Introduce a delayed action queue to complete purgatory actions outside purgatory. (#17177)
PR-17363 - KAFKA-16927; Handle expanding leader endpoints (#17363)
PR-17358 - KAFKA-15859: Fix the Unsupported version error when new admin connects to old broker (#17358)
PR-17325 - KAFKA-16106; Schedule timeout task to refresh classic group size metric (#17325)
PR-17335 - KAFKA-17428: Add retry mechanism for cleaning up dangling remote segments (#17335)
PR-17168 - KAFKA-17525 Convert the UnknownServerException to InvalidRequestException when altering client-metrics config at runtime (#17168)
PR-17356 - KAFKA-17658 Move BootstrapControllersIntegrationTest to kafka.server (#17356)
PR-17350 - KAFKA-17684 Update our java build versions (#17350)
PR-15995 - KAFKA-16469: Metadata schema checker (#15995)
PR-17293 - KAFKA-17613: Remove ZK migration code (#17293)
PR-17355 - KAFKA-17685 Define common testRuntimeOnly dependencies (#17355)
PR-15838 - KAFKA-16649: Remove lock from DynamicBrokerConfig.removeReconfigurable (#15838)
PR-17349 - KAFKA-17469: Move persister related classes to persister pkg. (#17349)
PR-17342 - KAFKA-17674: Fix bug on update positions of newly added partitions (#17342)
PR-17320 - KAFKA-17451 Remove deprecated consumer#committed (#17320)
PR-17312 - KAFKA-17511 Move ElectLeadersRequestOps to ElectLeadersRequest (#17312)
PR-17279 - KAFKA-17500: Metadata redirection for NOT_LEADER_OR_FOLLOWER (#17279)
PR-16843 - KAFKA-17285 Consider using Utils.closeQuietly to replace CoreUtils.swallow when handling Closeable objects (#16843)
PR-17318 - KAFKA-17589 Move JUnit extensions to test-common module (#17318)
PR-17346 - KAFKA-17680 Add timeout to streams test teardown (#17346)
PR-17251 - KAFKA-16974 KRaft support in SslAdminIntegrationTest (#17251)
PR-17311 - KAFKA-17258 Migrate AdminFenceProducersIntegrationTest to ClusterTestExtensions framework (#17311)
PR-17149 - KAFKA-17367: Share coordinator persistent batch merging algorithm. [3/N] (#17149)
PR-17282 - KAFKA-16733: Add share group record support to OffsetsMessageParser (#17282)
PR-17317 - KAFKA-17657 Replace the consumer-fetch-manager-metrics by groupName (#17317)
PR-16443 - KAFKA-16308 [3/N]: Introduce feature dependency validation to UpdateFeatures command (#16443)
PR-17323 - KAFKA-16769 Remove add.source.alias.to.metrics configuration (#17323)
PR-17336 - KAFKA-17673 Switch back to statuses API (#17336)
PR-17334 - KAFKA-17656 Replace string concatenation with parameterized logging for PartitionChangeBuilder (#17334)
PR-17204 - KAFKA-17540: Create script for updating a reference of latest cached trunk commit (#17204)
PR-17280 - KAFKA-17606: Include Rat errors in GitHub workflow summary (#17280)
PR-1436 - disable flakey test
PR-16522 - KAFKA-17078: Add SecurityManagerCompatibility shim (#16522)
PR-17304 - KAFKA-17634 Tweak wakeup logic to match WakeupTrigger changes (#17304)
PR-17209 - KAFKA-17109: Move lock backoff retry to streams TaskManager (#17209)
PR-17132 - KAFKA-17498: Reduce the number of remote calls when serving LIST_OFFSETS request (#17132)
PR-17314 - KAFKA-17653 Update Scala version to 2.13.15 for support Java 23 (#17314)
PR-17263 - KAFKA-17473 Speed Up ClientTelemetryTest (#17263)
PR-16761 - KAFKA-12823 Remove Deprecated method KStream#through (#16761)
PR-17215 - KAFKA-6197: Update Streams API and Javadoc references in documentation (#17215)
PR-17305 - KAFKA-17636 Fix missing SCRAM bootstrap records (#17305)
PR-17016 - KAFKA-14572: Migrate EmbeddedKafkaCluster used by Streams integration tests from EmbeddedZookeeper to KRaft (#17016)
PR-17284 - KAFKA-17619: Remove zk type and instance from ClusterTest (#17284)
PR-17244 - KAFKA-17581: AsyncKafkaConsumer can’t unsubscribe invalid topics (#17244)
PR-17289 - KAFKA-17626: Move common fetch related classes from storage to server-common (#17289)
PR-17290 - KAFKA-17628 New workflows for automating run approvals (#17290)
PR-17259 - KAFKA-16331: remove KafkaClientSupplier from StreamsProducer (#17259)
PR-17182 - KAFKA-17488: Cleanup (test) code for Kafka Streams “metric version” (#17182)
PR-17093 - KAFKA-17277: [2/2] Add feature dependency command to the storage and the feature command tool (#17093)
PR-16912 - KAFKA-16683 Extract security-related helpers from scala.TestUtils to java class (#16912)
PR-17165 - KAFKA-17154: New consumer subscribe may join group without a call to consumer.poll (#17165)
PR-17223 - KAFKA-17563 Move RequestConvertToJson to server module (#17223)
PR-17146 - KAFKA-17608, KAFKA-17604, KAFKA-16963; KRaft controller crashes when active controller is removed (#17146)
PR-17081 - KAFKA-16963: Ducktape test for KIP-853 (#17081)
PR-17288 - KAFKA-17621; Reduce logging verbosity on ConsumerGroupHeartbeat path (#17288)
PR-16719 - KAFKA-14562 [1/2]: Implement epoch bump after every transaction (#16719)
PR-16982 - KAFKA-16792: Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0) (#16982)
PR-17276 - KAFKA-17612 Remove some tests that only apply to ZK mode or migration (#17276)
PR-17274 - KAFKA-17571; Revert “MINOR: Log pending join members (#17219)” (#17274)
PR-17277 - KAFKA-17496: Add heterogeneous case to TargetAssignmentBuilderBenchmark (#17277)
PR-17258 - KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations (#17258)
PR-17112 - KAFKA-15859: Add timeout field to the ListOffsets request (#17112)
PR-17163 - KAFKA-17057: Add RETRY option to ProductionExceptionHanlder (#17163)
PR-17265 - KAFKA-14563: add feature version supports in the producers and ApiVersions (#17265)
PR-17231 - KAFKA-16908 Refactor QuorumConfig with AbstractConfig (#17231)
PR-17240 - KAFKA-17520 Align ducktape version in tests/docker/Dockerfile and tests/setup.py (#17240)
PR-17267 - KAFKA-17602 Remove ConfigUtils.translateDeprecatedConfigs from JmxReporter (#17267)
PR-17222 - KAFKA-17087 Deprecate delete-config of TopicCommand (#17222)
PR-17257 - KAFKA-17592; Support for SubscribedTopicsRegex in ConsumerGroupHeartbeat RPC (#17257)
PR-17233 - KAFKA-17578: Remove partitionRacks from TopicMetadata (#17233)
PR-17193 - KAFKA-17076: retain last batch in each round of cleaning (#17193)
PR-17080 - KAFKA-17465 Refactor getMembersFromGroup to be non-blocking (#17080)
PR-17252 - KAFKA-17585 offsetResetStrategyTimestamp should return long instead of Long (#17252)
PR-17174 - KAFKA-17512 Move LogSegmentTest to storage module (#17174)
PR-17237 - KAFKA-17530 Remove blacklist/whitelist from ReplaceField (#17237)
PR-17262 - KAFKA-17469: Moved share external interfaces to share module. (#17262)
PR-17250 - KAFKA-17459 Stablize reassign_partitions_test.py (#17250)
PR-17253 - Update zstd-jni lib (#17253)
PR-17133 - KAFKA-17495: Factor out assignor benchmark code into utils class (#17133)
PR-17226 - KAFKA-17575 Remove unnecessary file.deleteOnExit call (#17226)
PR-17212 - KAFKA-16331 remove EOSv1 from StreamsProducer (#17212)
PR-17179 - KAFKA-17528 Remove whitelist/blacklist from JMXReporter (#17179)
PR-17170 - KAFKA-16331: remove EOSv1 config from StreamsConfig (#17170)
PR-17234 - KAFKA-17567 Remove TestTruncate (#17234)
PR-16957 - KAFKA-16813 Add global timeout (60s) for @ClusterTemplate, @ClusterTest and @ClusterTests (#16957)
PR-17208 - KAFKA-17542: Use actions/labeler for automatic PR labeling (#17208)
PR-17211 - KAFKA-17356 add integration test for KAFKA-17310 (#17211)
PR-17220 - KAFKA-17555 uncomment all checks of testCommonNameLoggingTrustManagerMixValidAndInvalidCertificates (#17220)
14c45bed - KAFKA-17579: Dynamic LogCleaner configurations are picked up on restart
PR-17210 - KAFKA-17543: Improve and clarify the error message about generated broker IDs in migration (#17210)
PR-17117 - KAFKA-17472 Speed Up DescribeConsumerGroupTest (#17117)
PR-17218 - Revert “KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#16295)” (#17218)
PR-17042 - KAFKA-14482 Move LogLoader to storage module (#17042)
PR-17110 - KAFKA-16331 Remove EOSv1 from Kafka Streams integration tests (#17110)
PR-16867 - KAFKA-17322: Document required header versions in Protocol Guide (#16867)
PR-17122 - KAFKA-17494: Document message structure in Protocol Guide (#17122)
PR-16602 - KAFKA-15859 Make RemoteListOffsets call an async operation (#16602)
PR-16885 - KAFKA-17066 new consumer updateFetchPositions all in background thread (#16885)
PR-17083 - KAFKA-16027: Refactor testUpdatePartitionLeadership (#17083)
PR-17173 - KAFKA-17513 Move LogSegmentsTest to storage module (#17173)
PR-17192 - KAFKA-17543: Enforce that broker.id.generation.enable is not used when migrating to KRaft (#17192)
PR-17194 - Update to 4.1.0 of setup-gradle action (#17194)
PR-16213 - KAFKA-16681 Rewrite MiniKDC by Java (#16213)
PR-16493 - KAFKA-17036 KIP-919 supports for createAcls, deleteAcls, describeAcls (#16493)
PR-17159 - KAFKA-16468: verify that migrating brokers provide their inter.broker.listener (#17159)
PR-17154 - KAFKA-17508: Adding some guard for fallback deletion logic (#17154)
PR-17136 - KAFKA-17502: Modified commitSync() and close() handling in clients (#17136)
PR-17115 - KAFKA-17489: Do not handle failed tasks as tasks to assign (#17115)
PR-17082 - KAFKA-12601 Remove deprecated delegation.token.master.key (#17082)
PR-17180 - KAFKA-17524: Add timeout to StreamThreadTest (#17180)
PR-17171 - KAFKA-17427: Deprecate leaking *_DOC variables in StreamsConfig (#17171)
PR-17164 - KAFKA-17253: Deprecate Leaking Getter Methods in Joined Helper Class (#17164)
PR-17172 - KAFKA-17410: Disable testPollThrowsInterruptExceptionIfInterrupted for AsyncConsumer (#17172)
PR-17059 - KAFKA-12829: Remove deprecated StreamsBuilder#addGlobalStore of old Processor API (#17059)
PR-17145 - KAFKA-8666: Improve Documentation on usage of Materialized config object (#17145)
PR-17126 - KAFKA-16332 Remove Deprecated builder methods for Time/Session/Join/SlidingWindows (#17126)
PR-17166 - KAFKA-15073 Close stale PRs [2/n] (#17166)
PR-16969 - KAFKA-17400: Added share fetch purgatory for delaying share fetch requests (#16969)
PR-17075 - KAFKA-17448: New consumer seek should update positions in background thread (#17075)
PR-17137 - KAFKA-17231 Add missing node latency metrics (#17137)
PR-17138 - KAFKA-17392 Remove whitelist option in ConsoleConsumerOptions (#17138)
PR-17046 - KAFKA-17347 Add missing client-metrics option to kafka-configs.sh (#17046)
PR-17116 - KAFKA-17109: implement exponential backoff for state directory lock (#17116)
PR-16916 - KAFKA-17290: Added Integration tests for ShareFetch and ShareAcknowledge APIs (#16916)
PR-17027 - KAFKA-17435 remove use.incremental.alter.configs (#17027)
PR-17124 - KAFKA-14995: Automate asf.yaml collaborators refresh (#17124)
PR-17108 - KAFKA-16331: Remove EOSv1 from Kafka Streams system tests (#17108)
PR-17004 - KAFKA-15793 Fix ZkMigrationIntegrationTest#testMigrateTopicDeletions (#17004)
PR-17084 - KAFKA-17458 Add 3.8 to transactions_upgrade_test.py, transactions_mixed_versions_test.py, and kraft_upgrade_test.py (#17084)
PR-17128 - KAFKA-17492 skip features with minVersion of 0 instead of replacing 0 with 1 when BrokerRegistrationRequest < 4 (#17128)
PR-17129 - KAFKA-17224 Make ForeachProcessor internal (#17129)
PR-16898 - KAFKA-17306; Soften the validation when replaying tombstones (#16898)
PR-17135 - KAFKA-17311 Add groupProtocol parameter to testClientInstanceId, testClientInstanceIdInvalidTimeout, and testClientInstanceIdNoTelemetryReporterRegistered (#17135)
PR-17071 - KAFKA-17418: Improve markdown formatting in junit.py (#17071)
PR-17114 - KAFKA-17491: Move BrokerServerMetrics to server module (#17114)
PR-17127 - KAFKA-16830 Remove the scala version formatters support (#17127)
PR-17044 - KAFKA-14772; Add ConsumerGroupHeartbeat and ConsumerGroupDescribe API to AuthorizerIntegrationTest (#17044)
PR-16896 - KAFKA-17349 Make sure all IT have “quorum” input arguments (#16896)
PR-17131 - KAFKA-17497 Add e2e for zk migration with old controller (#17131)
PR-17011 - KAFKA-17367: Introduce share coordinator [2/N] (#17011)
PR-17109 - KAFKA-17470: CommitRequestManager should record failed request only once even if multiple errors in response (#17109)
PR-17097 - KAFKA-17482: Make share partition initialization async (KIP-932) (#17097)
PR-16127 - KAFKA-17477 Migrate TopicCommand test to new test infra (#16127)
PR-17125 - KAFKA-13588 We should consolidate changelogFor methods to simplify the generation of internal topic names (#17125)
PR-16676 - KAFKA-17137 Ensure Admin APIs are properly tested (topic-related) (#16676)
PR-16868 - KAFKA-17323 Document UINT16 and COMPACT_RECORDS in Protocol Guide (#16868)
PR-17005 - KAFKA-16863 : Deprecate default exception handlers (#17005)
PR-16505 - KAFKA-14460: Skip removed entries from in-memory KeyValueIterator (#16505)
PR-17121 - KAFKA-17479 Fail the whole pipeline if junit step times out [4/n] (#17121)
PR-17106 - KAFKA-17479 Fix ignoreFailures logic in CI workflow [3/n] (#17106)
PR-17118 - KAFKA-15648 Update leader volatile before handleLeaderChange in LocalLogManager (#17118)
PR-17094 - KAFKA-17457 Don’t allow ZK migration to start without transactions (#17094)
PR-17096 - KAFKA-17483: Complete pending share fetch requests on broker close (#17096)
PR-17098 - KAFKA-17479 Relocate junit XML files [2/n] (#17098)
PR-17054 - KAFKA-16448: Add timestamp to error handler context (#17054)
PR-17090 - KAFKA-16188: Delete kafka.common.MessageReader (#17090)
PR-17066 - KAFKA-17479 Allow “:jar” tasks to be cached [1/n] (#17066)
PR-16967 - KAFKA-17406: Move ClientIdAndBroker to server-common module (#16967)
PR-16986 - KAFKA-17414 Move RequestLocal to server-common module (#16986)
PR-17067 - KAFKA-17454 Fix failed transactions_mixed_versions_test.py when running with 3.2 (#17067)
PR-17078 - KAFKA-17474 fix state transition in GlobalStreamThread (#17078)
PR-16717 - KAFKA-17137 Ensure Admin APIs are properly tested (consumer group and quota) (#16717)
PR-17051 - KAFKA-17412: add doc for unclean.leader.election.enable in KRaft (#17051)
PR-16973 - KAFKA-17277: [1/2] Add version mapping command to the storage tool and feature command tool (#16973)
PR-16517 - KAFKA-16928: Test all of the request and response methods in RaftUtil (#16517)
PR-17039 - KAFKA-17425: Improve coexistence of consumer and share groups (#17039)
PR-17074 - KAFKA-17468 Move kafka/log/remote/quota classes to storage module (#17074)
PR-17045 - KAFKA-15859 Introduce remote.list.offsets.request.timeout.ms dynamic config (#17045)
PR-16833 - KAFKA-17294 Handle retriable errors when fetching offsets in new consumer (#16833)
PR-16665 - KAFKA-15853 Move TransactionLogConfig and TransactionStateManagerConfig getters out of KafkaConfig (#16665)
PR-17015 - KAFKA-17430: Move RequestChannel.Metrics/RequestMetrics to server module (#17015)
PR-17061 - KAFKA-17450 Reduced the handlers for handling ShareAcknowledgeResponse (#17061)
PR-16905 - KAFKA-17137 Ensure Admin APIs are properly tested (token-related) (#16905)
PR-16956 - KAFKA-17442: Handled persister errors with write async calls (KIP-932) (#16956)
PR-16864 - KAFKA-17320 Move SensorAccess to server-common module (#16864)
PR-17069 - KAFKA-17461 move the .github/README.md to .github/workflows/README.md (#17069)
PR-16844 - KAFKA-17293: New consumer HeartbeatRequestManager should rediscover disconnected coordinator (#16844)
PR-16873 - KAFKA-17331 Throw unsupported version exception if the server does NOT support EarliestLocalSpec and LatestTieredSpec (#16873)
PR-17028 - KAFKA-17437 Upgrade commons-validator from 1.7 to 1.9.0 (#17028)
PR-17023 - KAFKA-12826: Remove Deprecated Class Serdes (#17023)
PR-17060 - KAFKA-17449 Move Quota classes to server-common module (#17060)
PR-16648 - KAFKA-17137 Feat admin client it acl configs (#16648)
PR-17019 - KAFKA-17433 Add a deflake Github action (#17019)
PR-16933 - KAFKA-15909 Throw error when consumer configured with empty/whitespace-only group.id for LegacyKafkaConsumer (#16933)
PR-16983 - KAFKA-17386 Remove broker-list, threads and num-fetch-threads in ConsumerPerformance (#16983)
PR-16744 - KAFKA-16327: Removed Deprecated variable StreamsConfig#TOPOLOGY_OPTIMIZATION (#16744)
PR-17030 - KAFKA-17377: Consider using defaultApiTimeoutMs in AsyncKafkaConsumer#unsubscribe (#17030)
PR-16791 - KAFKA-12829: Remove deprecated Topology#addGlobalStore of old Processor API (#16791)
PR-16778 - KAFKA- 12834 : Removed Deprecated method under MockProcessorContext (#16778)
PR-16673 - KAFKA-17064: New consumer assign should update assignment in background thread (#16673)
PR-17024 - KAFKA-17434: Do not test impossible scenarios in upgrade_test.py (#17024)
PR-16992 - KAFKA-17390 Remove broker-list in GetOffsetShell (#16992)
PR-16958 - KAFKA-17388 Remove broker-list from VerifiableProducer (#16958)
PR-16694 - KAFKA-17170: Add test to ensure new consumer acks reconciled assignment even if first HB with ack lost (#16694)
PR-17013 - KAFKA-17413; Re-introduce group.version feature flag (#17013)
PR-16959 - KAFKA-17062: handle dangling “copy_segment_start” state when deleting remote logs (#16959)
PR-16906 - KAFKA-12829: Remove the deprecated method init(ProcessorContext, StateStore) from the StateStore interface (#16906)
PR-16866 - KAFKA-12670: Support configuring unclean leader election in KRaft (#16866)
PR-16620 - KAFKA-15746: KRaft support in ControllerMutationQuotaTest (#16620)
PR-16904 - KAFKA-15406: Add the ForwardingManager metrics from KIP-938 (#16904)
PR-17017 - KAFKA-17426; Check node directory id for KRaft (#17017)
PR-17018 - KAFKA-17432: Fix threads alive after shutdown (#17018)
PR-17012 - KAFKA-17422: Adding copySegmentLatch countdown after expiration task is over (#17012)
PR-16879 - KAFKA-14262 Deletion of MirrorMaker v1 deprecated classes & tests (#16879)
PR-16974 - KAFKA-17403 Generate HB to leave on pollOnClose if needed (#16974)
PR-16955 - KAFKA-17396: Fix releasing session on final epoch (#16955)
PR-17003 - KAFKA-16972: Move BrokerTopicStats to storage module (#17003)
PR-16887 - KAFKA-17327; Add support of group in kafka-configs.sh (#16887)
PR-16644 - KAFKA-17038 KIP-919 supports for alterPartitionReassignments and listPartitionReassignments (#16644)
PR-16963 - KAFKA-17341 Refactor consumer heartbeat request managers (#16963)
PR-16985 - KAFKA-16330: Remove deprecated methods of TaskId and make deprecated members private (#16985)
PR-15482 - KAFKA-16335: Remove deprecated method of StreamPartitioner (#15482)
12506862 - reconcile develocity changes
PR-16921 - KAFKA-17367: Share coordinator infra classes [1/N] (#16921)
PR-17000 - KAFKA-17382 cleanup out-of-date configs of config_property (#17000)
PR-16980 - KAFKA-17399 Apply LambdaValidator to code base (#16980)
PR-16878 - KAFKA-17324: Set config group.protocol to classic in Streams (#16878)
PR-16987 - KAFKA-17373 Add print.epoch to kafka-console-share-consumer.sh/kafka-console-consumer.sh (#16987)
PR-16998 - KAFKA-17416 Add a checkstyle rule to suppress all generated code (#16998)
PR-16945 - KAFKA-14048; [2/2] Use the new group coordinator by default in 4.0 (#16945)
PR-16914 - KAFKA-17100: GlobalStreamThread#start should not busy-wait (#16914)
PR-16932 - KAFKA-17360 local log retention ms/bytes “-2” is not treated correctly (#16932)
PR-16876 - KAFKA-17331 Set correct version for EarliestLocalSpec and LatestTieredSpec (#16876)
PR-16981 - KAFKA-12824 Delete unused doBranch method (#16981)
PR-16858 - KAFKA-17315 Fix the behavior of delegation tokens that expire immediately upon creation in KRaft mode (#16858)
PR-16979 - KAFKA-17409 Remove deprecated constructor of org.apache.kafka.clients.producer.RecordMetadata (#16979)
PR-16949 - KAFKA-16379; Coordinator event queue, processing, flush, purgatory time histograms (#16949)
PR-16920 - KAFKA-17291: Add integration test for share group list and describe (#16920)
PR-16960 - KAFKA-17193: Pin all external GitHub Actions to the specific git hash (#16960)
PR-16625 - KAFKA-17112: Manually stop task manager if stream thread is not in CREATED state (#16625)
PR-16762 - KAFKA-16329: Remove deprecated IQ metadata classes in Kafka Streams (#16762)
c7f0ade7 - KAFKA-16334: Remove –bootstrap-servers from kafka-streams-application-reset
PR-16941 - KAFKA-17371: Fix DefaultTaskExecutorTest.shouldUnassignTaskWhenRequired (#16941)
PR-16935 - KAFKA-17372 Move ThrottledChannelExpirationTest#testThrottledChannelDelay and ThrottledChannel to server module (#16935)
PR-16764 - KAFKA-16333: remove deprecated join method with named param (#16764)
PR-16893 - KAFKA-17336 Add IT to make sure the production MV does not use unstable version of LIST_OFFSET (#16893)
PR-16943 - KAFKA-17370 Move LeaderAndIsr to metadata module (#16943)
PR-1427 - CONFLUENT: Update service.yml
PR-16850 - KAFKA-16324 Move BrokerApiVersionsCommand to tools (#16850)
PR-16942 - KAFKA-17378 Fixes for performance testing (#16942)
PR-16848 - KAFKA-17305; Check broker registrations for missing features (#16848)
PR-16900 - KAFKA-17333; ResignedState should not notify of leader change (#16900)
PR-16937 - KAFKA-14048; [1/N] Use the new group coordinator by default in 4.0 (#16937)
PR-16934 - KAFKA-17279: Handle retriable errors from offset fetches (#16826) (#16934)
PR-16661 - KAFKA-17151 Remove waitForCondition when detecting thread leak (#16661)
PR-16938 - KAFKA-16736 Remove offsets.commit.required.acks in 4.0 (#16938)
PR-16659 - KAFKA-17169: Add EndpointsTest (#16659)
PR-16658 - KAFKA-17137 Ensure Admin APIs are properly tested (#16658)
PR-16826 - KAFKA-17279: Handle retriable errors from offset fetches (#16826)
PR-16903 - KAFKA-17325: Updated result handling in ShareConsumeRequestManager::commitAsync(). (#16903)
PR-16897 - KAFKA-17350: Improve share group describe for empty groups (#16897)
PR-16646 - KAFKA-16900 kafka-producer-perf-test reports error when using transaction. (#16646)
PR-16707 - KAFKA-17181 Replace fileChannel.write with Utils.writeFully to prevent partial write (#16707)
PR-16803 - KAFKA-12824 Remove Deprecated method KStream#branch (#16803)
PR-16907 - KAFKA-17332; Controller always flush and can call resign on observers (#16907)
PR-12782 - KAFKA-14336: MetadataResponse#convertToNodeArray uses iteration (#12782)
PR-16924 - KAFKA-17369: Remove Reflections from logging and update licenses (#16924)
PR-16908 - KAFKA-17180 Upgrade gradle from 8.8 to 8.10 (#16908)
PR-16925 - KAFKA-17368 Add delivery count to kafka-console-share-consumer.sh (#16925)
PR-16888 - KAFKA-17346: Create :share Gradle module (#16888)
PR-16913 - KAFKA-17357 Replace the deprecated retry.maxRetries / retry.maxFailures` (#16913)
PR-16604 - KAFKA-15203: Use Classgraph since org.reflections is no longer under maintenance (#16604)
PR-16849 - KAFKA-12989 MockClient should respect the request matcher passed to prepareUnsupportedVersionResponse (#16849)
PR-16890 - KAFKA-16749: [Minor] Addressed additional review comments (#16890)
PR-16877 - KAFKA-17330: New share-coordinator module. Added record schemas. (#16877)
PR-16911 - KAFKA-17086 add missing Java 21 to ops.html (#16911)
PR-16883 - KAFKA-17342 Moved common coordinator code to separate module (#16883)
PR-16901 - Make TestFeatureVersion 2 always map to MetadataVersion.latestTesting (#16901)
PR-16902 - KAFKA-17352 Migrate from Gradle Enterprise Gradle Plugin to Develocity Gradle Plugin (#16902)
PR-16892 - KAFKA-16842; Fix config validation and support unknown voters (#16892)
PR-16894 - KAFKA-16753: [MINOR] Addressing additional review comments (#16894)
PR-16823 - KAFKA-17283: Integration test for share group heartbeat (#16823)
PR-16860 - KAFKA-16723 : Added kafka-console-share-consumer.sh tool. (#16860)
PR-16891 - KAFKA-16752: [MINOR] Addressed additional review comments (#16891)
PR-16875 - KAFKA-16818 Move event processing-related tests from ConsumerNetworkThreadTest to ApplicationEventProcessorTest (#16875)
PR-16775 - KAFKA-17238 Move VoterSet and ReplicaKey from raft.internals to raft (#16775)
PR-16872 - KAFKA-17318 ConsumerRecord.deliveryCount and remove deprecations (#16872)
PR-16870 - KAFKA-17326 The LIST_OFFSET request is removed from the “Api Keys” page (#16870)
PR-16862 - KAFKA-17304; Make RaftClient API for writing to log explicit (#16862)
PR-16845 - KAFKA-17272: [1/2] System test framework for consumer protocol migration (#16845)
PR-16859 - KAFKA-14510; Extend DescribeConfigs API to support group configs (#16859)
PR-16835 - KAFKA-16714: kafka-share-groups.sh list and describe (#16835)
PR-16832 - KAFKA-17239 add request-latency metrics for node in admin client (#16832)
PR-16786 - KAFKA-17247 Revised share group record schemas (#16786)
PR-16579 - KAFKA-16682 Rewrite JaasTestUtils by Java (#16579)
PR-16167 - KAFKA-16689 Move LogValidatorTest to storage module (#16167)
PR-16865 - KAFKA-17319 change ListOffsetsRequest latestVersionUnstable to false (#16865)
PR-16836 - KAFKA-17300: Add document for new tiered storage feature in v3.9.0. (#16836)
PR-16863 - Kafka 16887 : Upgrade the document to add remote copy/fetch quotas metrics values. (#16863)
PR-16847 - KAFKA-17292: Introduce share coordinator protocol config (#16847)
PR-16838 - KAFKA-17303 Enable testPutControllersInBootstrapBrokersConfig (#16838)
PR-16841 - KAFKA-17018: update MetadataVersion for the Kafka release 3.9 (#16841)
PR-16672 - KAFKA-17190: AssignmentsManager gets stuck retrying on deleted topics (#16672)
PR-16792 - KAFKA-16746: Implemented handleShareAcknowledgeRequest RPC including unit tests (#16792)
PR-16846 - KAFKA-17289: ShareGroupDescribe integration test (#16846)
PR-16856 - KAFKA-17310 locking the offline dir can destroy the broker exceptionally (#16856)
PR-15067 - KAFKA-14511; Extend AlterIncrementalConfigs API to support group config (#15067)
PR-16592 - KAFKA-17056 Convert producer state metadata schemas to use generated protocol (#16592)
PR-16821 - KAFKA-17270 Let test code use Exit.java rather than Exit.scala (#16821)
PR-16828 - KAFKA-17288 Removed tracking partition member epoch (KIP-932) (#16828)
PR-16855 - KAFKA-17297 stabalize testHandleEndQuorumRequest (#16855)
PR-16857 - KAFKA-17312 Fix tests shouldForwardAllDbOptionsCalls and shouldOverwriteAllOptionsMethods in RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest (#16857)
PR-16687 - KAFKA-17137 Add integration tests for admin client (createPartitions and quota) (#16687)
PR-16822 - KAFKA-17273 Migrate BootstrapControllersIntegrationTest to use ClusterTestExtensions (#16822)
PR-16790 - KAFKA-17035 Add debug log to retention cleanupLogs method to help troubleshoot issues (#16790)
PR-16820 - KAFKA-17067; Fix KRaft transition to CandidateState (#16820)
PR-16777 - KAFKA-17240 Try to complete delyed ops for all purgatories even though one of delayed op throws exception (#16777)
PR-16805 - KAFKA-16328 Remove Deprecated config from StreamsConfig (#16805)
PR-16751 - KAFKA-17225: Refactor consumer membership managers (#16751)
PR-16809 - KAFKA-12830: Remove Deprecated constructor in TimeWindowedDeserializer and TimeWindowedSerde (#16809)
PR-16813 - KAFKA-12832 remove deprecated methods in RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter (#16813)
PR-16800 - KAFKA-17228; Static member using new protocol should always replace the one using the old protocol (#16800)
PR-16825 - KAFKA-17267; Don’t return REQUEST_TIMED_OUT for OFFSET_FETCHes (#16825)
PR-16837 - KAFKA-16534; Implemeent update voter sending (#16837)
PR-16774 - KAFKA-16523; kafka-metadata-quorum: support add-controller and remove-controller (#16774)
PR-16753 - KAFKA-17223 Retrying the call after encoutering UnsupportedVersionException will cause ConcurrentModificationException (#16753)
PR-16817 - KAFKA-17269 Fix ConcurrentModificationException caused by NioEchoServer.closeNewChannels (#16817)
PR-16807 - KAFKA-15875: Stops leak Snapshot in public methods (#16807)
PR-16830 - KAFKA-16521: Have Raft endpoints printed as name://host:port (#16830)
PR-16727 - KAFKA-17217: Batched acknowledge requests per node in ShareConsumeRequestManager (#16727)
PR-16773 - KAFKA-17242: Do not log spurious timeout message for MirrorCheckpointTask sync store startup (#16773)
PR-16767 - KAFKA-17232: Do not generate task configs in MirrorCheckpointConnector if initial consumer group load times out (#16767)
PR-16814 - KAFKA-17275: Move ReplicatedCounter to test scope (#16814)
PR-16765 - KAFKA-17236: Handle local log deletion when remote.log.copy.disabled=true (#16765)
PR-16819 - KAFKA-17276; replicaDirectoryId for Fetch and FetchSnapshot should be ignorable (#16819)
PR-16827 - KAFKA-16716: Add admin list and describe share groups (#16827)
PR-16797 - KAFKA-16742: Add share group describe in coordinator (KIP-932) (#16797)
PR-16747 - KAFKA-12828: Removed Deprecated methods under KeyQueryMetadata (#16747)
PR-16709 - KAFKA-16584: Make log processing summary configurable or debug–update upgrade-guide (#16709)
PR-16752 - KAFKA-17222 Remove the subclass of KafkaMetricsGroup (#16752)
PR-16652 - KAFKA-17137 Add integration tests for admin client (Transaction and UserScramCredentials related) (#16652)
PR-16456 - KAFKA-16745: Implemented handleShareFetchRequest RPC including unit tests (#16456)
PR-16795 - KAFKA-17262 Improve kafka-topics usage message (#16795)
PR-16782 - KAFKA-17227: Refactor compression code to only load codecs when used (#16782)
PR-16789 - KAFKA-17235 system test test_performance_service.py failed (#16789)
81edb74c - KAFKA-16533; Update voter handling
PR-16669 - KAFKA-16518: Implement KIP-853 flags for storage-tool.sh (#16669)
e49c8df1 - KAFKA-16533; Update voter handling
PR-16723 - KAFKA-17201 SelectorTest.testInboundConnectionsCountInConnectionCreationMetric leaks sockets and threads (#16723)
PR-16763 - KAFKA-17227: Update zstd-jni lib (#16763)
PR-16783 - KAFKA-16154: Broker returns offset for LATEST_TIERED_TIMESTAMP (#16783)
PR-16745 - KAFKA-16448: Unify error-callback exception handling (#16745)
PR-16653 - KAFKA-16855: remote log disable policy in KRaft (#16653)
PR-16693 - KAFKA-17205: Allow topic config validation in controller level in KRaft mode (#16693)
PR-16781 - KAFKA-16480: ListOffsets change should have an associated API/IBP version update (#16781)
PR-16780 - KAFKA-17245: Revert TopicRecord changes. (#16780)
PR-16715 - KAFKA-16390: add group.coordinator.rebalance.protocols=classic,consumer to broker configs when system tests need the new coordinator (#16715)
PR-16742 - KAFKA-9738: Deprecate old Processor API (#16742)
PR-16776 - KAFKA-16448: Update documentation (#16776)
PR-16748 - KAFKA-16666 Migrate GroupMetadataMessageFormatter` to tools module (#16748)
PR-16678 - KAFKA-17192 Fix MirrorMaker2 worker config does not pass config.provi… (#16678)
PR-16759 - KAFKA-16521; kafka-metadata-quorum describe command changes for KIP-853 (#16759)
PR-16755 - KAFKA-17230: Fix for consumer node latency metrics (#16755)
PR-16760 - KAFKA-17234: Partition.tryCompleteDelayedRequests should not throw (#16760)
PR-16300 - KAFKA-16448: Handle processing exceptions in punctuate (#16300)
PR-16736 - KAFKA-16448: Unify class cast exception handling for both key and value (#16736)
PR-16738 - Revert “KAFKA-16508: Streams custom handler should handle the timeout exceptions (#16450)” (#16738)
PR-16334 - KAFKA-16899 MembershipManagerImpl: rebalanceTimeoutMs variable name changed to commitTimeoutDuringReconciliation (#16334)
PR-16724 - KAFKA-17188: Ensure login and callback handler are closed upon encountering LoginException (#16724)
PR-16689 - KAFKA-16666 Migrate OffsetMessageFormatter to tools module (#16689)
PR-16675 - KAFKA-16448: Handle fatal user exception during processing error (#16675)
PR-16730 - KAFKA-17203 StreamThread leaking producer instances (#16730)
PR-16680 - KAFKA-17185 Declare Loggers as static to prevent multiple logger instances (#16680)
PR-16666 - KAFKA-17175 Remove interface BrokerNode and ControllerNode (#16666)
PR-16726 - KAFKA-17214: Add 3.8.0 version to core and client system tests (#16726)
PR-16728 - KAFKA-17214: Add 3.8.0 version to streams system tests (#16728)
PR-16650 - KAFKA-15469: Add documentation for configuration providers (#16650)
PR-16432 - KAFKA-16448: Add ErrorHandlerContext in deserialization exception handler (#16432)
PR-16433 - KAFKA-16448: Add ErrorHandlerContext in production exception handler (#16433)
f26f0b66 - tests/kafkatest/version.py: Add 3.9.0 as DEV_VERSION
0ec520a2 - Bump trunk to 4.0.0-SNAPSHOT
ksqlDB
PR-10741 - Remove zookeeper references from the codebase
PR-10739 - Remove zookeeper references
PR-10735 - Implement new SR client method getIdWithResponse
PR-10737 - Remove zookeeper license
PR-10733 - Fix backward compatibility of log4j1
PR-10732 - remove monitoring interceptor classes
PR-10731 - Pin JDK to 17
PR-10729 - Return a server error for host unavailability errors in pull queries.
PR-10722 - Update dependency Pygments to v2.15.1 [SECURITY] (7.1.x)
PR-10728 - Update the ZK notices text version under licenses
b0408e52 - Add comment and proper log message.
PR-10703 - Migrate jetty 9 to jetty 12
15443bd0 - ‘org.apache.kafka.common.errors.GroupIdNotFoundException’ import. Should be before ‘import org.apache.kafka.common.errors.GroupNotEmptyException;’.
a11521a7 - ‘org.apache.kafka.common.errors.GroupIdNotFoundException’ import. Should be before ‘org.apache.kafka.common.errors.RetriableException’.
ef35befc - Cleanup code.
PR-10726 - Update dependency jinja2 to v3.1.6 [SECURITY] (7.1.x)
fab70735 - Add logs.
1866bf04 - Keep poll time to be 10 ms, only after creating the consumer.
0dc3edf7 - Revert retries.
a10bbe2e - Poll consumers for long time to let them join the consumer group.
1cb51bec - Increase retries
4fc6b79d - Uncomment shouldListConsumerGroupsWhenTheyExist.
PR-10710 - Add a sleep for 100ms before the select queries.
PR-10708 - Removed JaasUtil’s zookeeper dependency for Ksql Build
PR-10707 - Zookeeper Deprecation (Moving to KRaft)
PR-10706 - Fix log4j2 config
PR-10705 - Downgrade jetty version to fix build
a4fe7a51 - changes in additional places
57537e6a - addressing comments
0f6f2a62 - abstracting oauth implementation
PR-10698 - Log4j to Log4j2 Migration
PR-10700 - Revert “Merge pull request”
PR-10699 - Upgrade antlr version to 4.10.1
PR-10695 - Set the default value for SecurityManager enablement to false as it is deprecated on java 21.
0a211a88 - corrected conflict
PR-10686 - update netty
PR-10678 - Query Plans and Topologies for kSQLDB 8.0
PR-10682 - Fix the compilation error.
PR-10630 - Added sonar.properties
b7c8a55f - bouncy castle fix
PR-10676 - FlatTransformValues Migration and Legacy Fallback to AlterConfigs Removed
PR-10672 - Merge Conflict Resolution (from 7.4.x to 7.5.x)
8fcad7f8 - remove jetty pin / outdated comment
be803959 - debug
313fd1da - debug
9c0edb4e - nit
90d5e47e - nit
PR-10659 - Fix the placement of default port number and capture the sub path while creating a client to ksqlDB.
PR-10657 - Fix the placement of default port number and capture the sub path while creating a client to ksqlDB.
PR-10655 - Fix the placement of default port number and capture the sub path while creating a client to ksqlDB.
PR-10653 - Fix the placement of default port number and capture the sub path while creating a client to ksqlDB.
f6c26e7a - Fix the placement of default port number and capture the sub path while creating a client to ksqlDB.
8bfe4b59 - Update vertx to 4.4.8 for 7.1.x
PR-10628 - Transform to Process Migration (2nd PR)
PR-10633 - refactor: refactored ksqltransformer and its implementations
PR-10627 - refactor: refactored for checkstyle
PR-10596 - Fix master build
PR-10620 - Fix jsonschema dependency
PR-10619 - Fix jsonschema dependency
PR-10613 - Fix jsonschema dependency
PR-10576 - adding block level status for semaphore
PR-10550 - Fix the deprecated api methods.
1f619471 - Fix checkstyle error
03a41110 - Use the actual window size instead of long max
REST Proxy
dc0155b0 - revert version bump
26d8d8f9 - merge version bump by bot
16d5bd68 - fix typo
15dc547a - restore property
abcb7731 - remove zk
ca430c3e - Remove zk notice for cp 8.0.x release
PR-1374 - Convert log4j2 properties file to yaml
e295cb84 - change while-loop conditions to not overcheck the request log
PR-1371 - Fix log4j pattern config
PR-1368 - Migrate reload4j (log4j1) to log4j2
PR-1358 - Jetty migration 9 to 12: kafka-rest
PR-1367 - refactor: changing the config introduced in the commit d65a0b3
PR-1360 - fix: return errors from SchemaUtils class rather than Optional.empty
PR-1359 - Handle null payload in POST requests
PR-1356 - perf: add singleton to SchemaRecordSerializerFactory
ace1de9f - openapi.yaml
0a3055c3 - fix unit tests
b17955a3 - integration tests
ef37ffed - consumer group manager impl
PR-1352 - Remove java-7-jdk dependency from debian build scripts
PR-1335 - Add API to fetch earliest and latest partition offsets
PR-1349 - Implement hashCode for ConsumerGroup.State to satisfy equals contract
PR-1348 - Use GroupState from AK instead of deprecated api
PR-1341 - Copy TestUtils#createBrokerConfig to avoid depending on upstream internal API
1233e45d - change imports to confluent package
a313d614 - change imports to confluent package
PR-1339 - Remove kafka_2.13 dep and exclude log4j2 compatibility jar
PR-1337 - Exclude log4j2 deps from kafka
PR-1333 - Change visibility of testInfo and quorumTestHarness to protected so they can be used by subclasses
PR-1338 - Fix build due to upstream change
PR-1334 - Use backward compatible method to fix downstream build
2ff8e32c - Remove unncessary code changes
cf536506 - Address comments
0b6b7b6f - Fix unit test failures after changing ConsumerGroupState to GroupState
970a3995 - Remove random print
2e2aa71d - Remove zk from integration tests and fix consumer group description lookup breaking change
PR-1326 - Temporarily disable unit tests in SchemaManagerImplTest
PR-1325 - Remove zk and replace jetty DOSFilter with Confluent fork
PR-1324 - Correct field name in ConsumerGroupData, consumer -> consumers to mach code/examples
PR-1307 - Remove/Disable ZK specific tests in Kafka Rest
16369e5e - [Update] Remove counting error codes for 200
fad6156c - [Update] Fixed assertion caused by counting 200 error code
8780d5fb - [Update] Remove equals and hashCode methods of ProduceRecordErrorCounter, add cutom matcher for easymocking ProduceErrorCounter
9b47ae1a - [UPDATE] Remove unused variables
aa44306c - Delete 1
823718c1 - [Update] Code structure changes
3e5af49c - [Update] Change to more detailed method and attribute names for ProduceRecordErrorCounter
61c5b940 - [Update] Fix format
0bc39fa3 - Delete my.properties
cd45cf2b - [Update] Change class name from ProduceCounter to ProduceRecordErrorCounter
39af2bac - Add back .gitignore
a6d4b1b0 - Delete .gitignore
a6b6caa9 - [Update] Add override equals method for ProduceCounter and modified ProduceActionTest accrodingly
8e8f325f - [DO NOT MERGE] Pushing for review only
c6cff764 - Delete my.properties
da4fae88 - [Update] Add comments to test_WhenProduceRequestWithMultipleRecords_ThenRequestLogHasAggregatedErrorCodes, modify variable/function names, avoided hard coding “Codes=”, corresponding changes to tests
6d8a2bff - [Update] Add an integration test for streaming produce with multiple records in one single request
3000a4ff - [Update] shorten expectings in streamingRequestsWithExceptions
ffc921ca - [Updated] Including counting with response 200 ok (previous version cannot work on local testings)
88e9d879 - Include counting error code with 200 ok
555a5849 - Produce V3 API - Improve visibility around produce-record errors
c94062ed - remove zk references
5da01411 - Remove zk notice for cp 8.0.x release
PR-565 - Pin JDK to 17
96e64e52 - resolve merge conflict from 7.8 to 7.9
PR-491 - Add configuration hsts.header.enable to control whether we response with HSTS header
345fcebb - Fix log4j pattern config
PR-561 - Upgrade log4j1 to log4j2
ec24728a - Fix for new changes merged in
f8f06361 - CustomLog fixed; No need to use Jetty 9 RequestLogHandler
fcba5cf4 - trigger cla-status-check
8f0dce70 - PR comment; ** role for MDS authz
6480173f - rename snihandler
c23b84c7 - add config: sni.host.check.enabled for SNI host checking in SecureRequestCustomizer
6bc44ca5 - comments
1c492d6f - more tests
c54a9d3f - add test
034b803a - Implement TenantPrefixSniHandler to perform prefix validation using the tenant name
d8e5f924 - Fix the way requestlog is set
7a6bcbcb - Cleanup code comments for security constraints
5475e6c5 - Use pinned jakarta versions from common
88744003 - Dedup httpclient() in tests
1c7e1851 - add comment for disabled test
7b3be310 - update SNIUtils
62f8d3e5 - change PropertyFileLoginModule package in SaslTest
9b93be44 - allow ambiguous http to go through servlet
fef52601 - Fix CustomInitTest setup; ServerContainerInitializer related
619e8166 - Fix Http2Test ambiguous segment - please review
6a459c97 - clean up the pom files
5ec83c01 - fix http client initialization in tests
5bf4b783 - add comment for RestConfig timeout change, unify pom version for websocket-api
dc32d30a - change ErrorHandler for Jetty 12 API
2803ca1b - Security Constraint related changes with comments for review
ae462b74 - fix roles related assertions; JakartaWebSocketServletContainerInitializer to register endpoints;
09fb3e38 - server taking too long to shutdown, bumping default timeout to 5seconds
a7e9fe48 - small fix to AuthUtilTest, getRoles() returns a Set now
78a1130b - modify websocket-server for jetty 12; fix for client-api build failures
d154b969 - Temp commit - revert it later
c347aea6 - fix examples,fips-test
ea3acc6f - getRoles(), validateRequest and handler fixes
4e40602f - Major fix for httpclient and SslContextFactory issues
97439b29 - update v9.53 DosFilter to be compatible with Jetty 12
3a76ebc9 - PR comments; header fixes
9d7d7408 - RolePrincipal and import fixes
85d30eb5 - Fix ResourceCollection, Constraint and other imports
1168d7fa - easy fixes; security imports
3f66161d - javax.ws.rs -> jakarta.ws.rs; fix tests
c2bde5b7 - Fix JakartaWebSocketServletContainerInitializer
7af7af7c - Update jersey,jackson,jakarta dependencies
9ab7aa62 - Fix authUtil securityHandler issues
3d1a7e14 - fix sniUtils SslConnection
fd761cb4 - More handler related fixes
45faefd0 - Fix compilation issues; Handler overrides
c963e46b - fix HandlerWrapper; use jakarta imports for httpServletRequest and Response
0be2567f - fix for HandlerCollection
1d5fa089 - Fix ServerContainer; remaining Filter imports
PR-553 - Override jetty version to 9.4.57.v20241219
48793a42 - Fix Filter, FilterChain, FilterConfig; use jakarta
63a4096a - Fix ServletRequest and ServletResponse; using jakarta
fb4c77c1 - Fix dispatcherType; Remove RequestLogHandler
dc53690e - fix for servletException; remaining httpservlet ones
770021db - fix httpservletrequest and httpservletresponse imports
d83c2b78 - Fix security imports; javax.servlet fixes pending
4f44892e - Temp fix for DoSFilter
882d9ab8 - Fixed some compilation issues; need to fix DoSFilter
3ae701c0 - Init commit; build passes with compilation failures
6f7f0fa6 - add test
c19acb95 - fix import
5b13d1ec - fmt
3b3ff728 - add config for forwarded request customizer
PR-547 - Allow attaching NetworkTrafficListener to connectors of unnamed application
PR-546 - Allow attaching NetworkTrafficListener to connectors of unnamed application
c073c5b9 - Handle CompletionExceptions wrapping other exceptions
PR-537 - [master] Allow for upgrade to jetty and unpin jetty-servlets
PR-536 - [7.9.x] Allow for upgrade to jetty and unpin jetty-servlets
PR-535 - [7.8.x] Allow for upgrade to jetty and unpin jetty-servlets
27412aa1 - Map GroupAuthorizationException to 403 code
979f2f91 - Added validator for PERCENTILE_MAX_LATENCY
PR-523 - Include request URI in SNI logging
b8926290 - remove api team from codeowners
PR-518 - adding block level status for semaphore
016fc099 - checkstyle changes
94b6b72c - Make percentile max latency configurable
PR-516 - Handle jetty 11+ behavior of NetworkTrafficServerConnector
PR-515 - Add DoSFilter from Jetty 9.4.53
PR-514 - Map UnknownTopicIdException to 404 code
PR-506 - Log unexpected SNI headers in REST
PR-508 - Don’t log RestConfig value when creating DEFAULT_SSL config
Schema Registry
PR-3715 - Ensure SR client cache for CP 8.0 is backward compat with 7.x.x
PR-3711 - Add warning log whenever baseUrl changes in RestService
PR-3710 - Improve unit test coverage (edge case handling) for SetCompatibilityMojoTest
d977dc30 - Add tests for MD5 calculations
PR-3707 - Fix reference to Jetty JAAS class
PR-3706 - Bump dependency versions for GCP
PR-3698 - Distinguish between null and missing props for PUT
PR-3700 - Remove zookeeper references in log4j
PR-3691 - Start with first URL in UrlList
PR-3693 - Ensure AvroConverter does not rely on field order
PR-3692 - Remove zookeeper dependency in 8.0.x
PR-3688 - Use aws-java-sdk-v2.version from common
PR-3690 - Downgrade aws sdk v2 to match kafka on 7.7.x
PR-3685 - Add support for hybrid handler
PR-3678 - Generate Java 11 compatible class files for client modules
PR-3669 - Support schema ID in header
PR-3682 - Ignore JSON schema fields not in the Java class
306f08dc - Upgrade mbknor library to 1.0.39.3
7505a200 - Handle default context properly for /config and /mode
PR-3664 - log schema reads, writes and deletes
PR-3648 - Update dependency junit:junit to v4.13.1 [SECURITY] (7.1.x)
PR-3667 - Remove deprecated older interface for subject name strategy
PR-3666 - Add RuleSet.isEmpty method
PR-3663 - Convert XML log4j2 properties files to YAML
PR-3662 - Update the ZK notices text version under licenses
PR-3661 - add new cache schema registry method
PR-3658 - Remove slf4j-reload4j dependency to fix runtime
PR-3656 - Add minimal validation for certain KMS key IDs
PR-3650 - Migrate slf4j-reload4j to log4j2
PR-3630 - Upgrade to Jetty 12, use jakarta APIs
PR-3642 - Upgrade log4j to log4j2
PR-3641 - adding retry test for ser/de/restservice
PR-3640 - Handle URL-encoded paths in ContextFilter
PR-3636 - Support new CachedSchemaRegistryClient in SchemaRegistryClientFactory
PR-3635 - Support new CachedSchemaRegistryClient in SchemaRegistryClientFactory
PR-3632 - Merge Conflict Resolution (from 7.9.x to master)
PR-3631 - deep copy for Schema
PR-3626 - Redact sensitive fields in the DLQ Action
PR-3625 - Return deleted flag for schemas via REST API
PR-3621 - Always override X-Forwarded-For header on follower call
PR-3622 - Upgrade Tink to 1.17.0
PR-3620 - Remove unstable annotation from Avro serdes
PR-3619 - Expand semantic check when looking up schemas
PR-3581 - SR dek paginations
PR-3616 - Update test to use qualified subject names and fix a typo
PR-3615 - Upgrade to aws sdk 2.30.33
PR-3614 - Increase max length for kek and rule names
PR-3613 - Exclude javapoet dependency from wire (requires Java 17)
PR-3610 - exclude an imported 3P util class from test coverage
PR-3609 - add dek-registry module for coverage aggregation
PR-3608 - Test coverage: fix the module and updated the tests.
76c315ae - Ensure use of DEK object is thread-safe
PR-3605 - Update deps for CSPs
PR-3604 - Update proto-related libs for Protbuf 4
PR-3597 - Remove java-7-jdk dependency from debian build scripts
PR-3600 - Fix message reader to allow for interactive usage
PR-3599 - Improve test coverage (no feature change)
PR-3590 - Add retry for schema exporter upon IOException
PR-3582 - add missing tests for DekRegistry
5e23bc86 - HostSslSocketFactory for bouncycastle fix.
PR-3592 - Enhance integration test w/additional lookup
PR-3585 - Upgrade to wire 5.3.0
PR-3591 - Call close on custom auth provider
edff633b - Convert test to JUnit5 to fix build
2d0c34e6 - Upgrade Tink to 1.16
PR-3584 - Upgrade json-skema to 0.20
PR-3576 - Upgrade cel to 0.5.1; jsonata to 2.5.1
PR-3578 - Pagination of SR APIs (Subject and Schema)
PR-3575 - Support Protobuf oneof fields in Data Contract rules
PR-3577 - changing access to public
PR-3573 - Upgrade commons.validator to 1.9.0
PR-3569 - Upgrade to Protobuf 4
PR-3566 - add missing tests for DekRegistry
PR-3570 - reverting changes on 7.9 and above
PR-3568 - Merge Conflict Resolution (from 7.5.x to 7.6.x)
PR-3564 - Fix OAuth tests due to AK changes
PR-3561 - Ensure that DEK lookups use applicable aliases
PR-3559 - Setting default SSLSocketFactory from HttpsURLConnection in RestService.
PR-3555 - Ensure lookup by schema logic matches logic during register
PR-3554 - Return creation time for schemas via REST API
PR-3551 - Add support for schema guids that are stable across contexts
PR-3544 - Upgrade everit json-schema to 1.14.5
PR-3540 - Return subject/version when getting schema by ID
PR-3542 - Bouncy Castle and SunJSSE compatibility fix (additional flows)
PR-3538 - Bouncy Castle and SunJSSE compatibility fix.
PR-3539 - Fix inline tag retrieval for JSON Schema with null in array
PR-3535 - Remove use of ZK in SASL cluster tests
PR-3533 - Use JDK 17 for 8.0.0
PR-3530 - Attempt to reenable possibly flakey test
PR-3529 - Add display name generator to ensure Kraft is used in integration tests
PR-3527 - set pagination limit for subjects to INT_MAX
PR-3523 - Retry on NotLeaderOrFollowerException
PR-3518 - Remove ZK from integration tests; upgrade to JUnit 5
PR-3491 - Update KafkaGroupLeaderElector.java
PR-3502 - Fix compilation
PR-3490 - enabling cp jar build through service.yml
PR-3473 - Remove some deprecated classes for CP 8.0
PR-3488 - Fix deprecated OAuthBearerLoginCallbackHandler
PR-3474 - adding block level status for semaphore
PR-3460 - Add avro array test
PR-3452 - Bump org.apache.maven.plugin version to 3.13.1 to support java 17
PR-3442 - Add PR template
PR-3443 - Enable semaphore pipeline on SC release branch
PR-3353 - Fix issues relating deprecated interfaces in upstream kafka