Confluent Platform Component Changelogs

This topic provides changelogs for the individual Confluent Platform components.

Version 7.9.0

Released February 2025

Community Features

Common

  • ae46dddf - update jetty
  • d1341a9b - add commons codec to dependency management
  • fbb9acf3 - pin version of mina-core to override version from jetty
  • 9277c65c - update netty to 4.1.115
  • 35ba77cd - Change version of bctls-fips to 1.0.13
  • bbde81e9 - Change version of bctls-fips to 1.0.13
  • c3786289 - Change version of bctls-fips to 1.0.13
  • f78bf5b6 - Change version of bctls-fips to 1.0.13
  • da4ebe39 - Change version of bctls-fips to 1.0.13
  • 86e4f1e2 - Change version of bctls-fips to 1.0.13
  • 93da41d2 - Change version of bctls-fips to 1.0.13
  • 60e02333 - Change in bouncycastle bctls due to downstream failures
  • 3bb5287b - Change in bouncycastle
  • 16ab459f - Change in bouncycastle
  • 9af7b9a3 - Change in bouncycastle
  • f478c73e - Change in bouncycastle
  • 644fbf03 - Change in bouncycastle
  • c02b71d4 - Change in bouncycastle
  • 62ad6c9a - Change in bouncycastle
  • PR-708 - Change in bouncycastle fips libraries upgrade
  • PR-706 - rename okio -> okio-jvm
  • 7fa06075 - update cyclonedx plugin( #704)
  • fb4f806f - add okio-jvm to dependencyManagement to match ce-kafka
  • PR-688 - Merge Conflict Resolution (from 7.6.x to 7.7.x)
  • PR-687 - update jetty to 9.4.56
  • PR-684 - define version of commons-io and add it to dependencyManagement
  • 79d5047d - upgrade avro to 1.11.4 to patch AVRO-3985
  • 39d5e6aa - upgrade avro to 1.11.4 to patch AVRO-3985

Kafka

  • PR-18833 - KAFKA-18758: NullPointerException in shutdown following InvalidConfigurationException (#18833)
  • PR-1579 - CCS CP release test regex updates
  • PR-18843 - KAFKA-806 Index may not always observe log.index.interval.bytes (#18843)
  • PR-18767 - KAFKA-18675 Add unit test to verify space separated brokers won’t cause exception for 3.8 and 3.9 (#18767)
  • PR-17836 - KAFKA-18028 the effective kraft version of –no-initial-controllers should be 1 rather than 0 (#17836)
  • PR-17773 - KAFKA-18001: Support UpdateRaftVoterRequest in KafkaNetworkChannel (#17773)
  • PR-18741 - KAFKA-18171: Revert the strict config validation for 3.8 and 3.9 (#18741)
  • PR-18736 - KAFKA-18663: Metadata v0-v3 should be undeprecated (#18736)
  • PR-1553 - [3.9] Update jetty to 9.4.57.v20241219
  • 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-18657 - KAFKA-18583; Fix getPartitionReplicaEndpoints for KRaft (#18657)
  • PR-18607 - KAFKA-17402: DefaultStateUpdated should transit task atomically (#18607)
  • PR-18587 - KAFKA-8862: Improve Producer error message for failed metadata update (#18587)
  • PR-18485 - Cherrypick lock backoff retry to 3.9 (#18485)
  • PR-18565 - KAFKA-18546: Use mocks instead of a real DNS lookup to the outside (#18565)
  • PR-18490 - KAFKA-18479: RocksDBTimeOrderedKeyValueBuffer not initialized correctly (#18490)
  • 155d7720 - HOTIFX: fix broken build
  • PR-18281 - KAFKA-18330: Update documentation to remove controller deployment limitations (#18281)
  • PR-17728 - KAFKA-17973: Relax Restriction for Voters Set Change (#17728)
  • PR-17527 - KAFKA-17455: fix stuck producer when throttling or retrying (#17527)
  • PR-18287 - KAFKA-18326: fix merge iterator with cache tombstones (#18287)
  • PR-18333 - KAFKA-18272: Deprecated protocol api usage should be logged at info level (3.9) (#18333)
  • PR-18323 - KAFKA-18352: DeleteGroups v0 incorrectly tagged as deprecated (3.9) (#18323)
  • PR-18306 - KAFKA-18342 Use File.exist instead of File.exists to ensure the Vagrantfile works with Ruby 3.2+ (#18306)
  • 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-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-18207 - KAFKA-18263; Group lock must be acquired when reverting static membership rejoin (#18207)
  • PR-18127 - KAFKA-18199; Fix size calculation for nullable tagged structs (#18127)
  • PR-17352 - KAFKA-17030; Unattached voters will fetch from bootstrap servers (#17352)
  • PR-17920 - KAFKA-18047: Add org.apache.kafka.automatic.config.providers to System Properties section (#17920)
  • PR-17970 - KAFKA-18100 Using block suppresses all errors (#17970)
  • PR-17919 - KAFKA-17299: add unit tests for previous fix (#17919)
  • PR-17899 - KAFKA-17299: Fix Kafka Streams consumer hang issue (#17899)
  • PR-17883 - KAFKA-18051: Disallow creating ACLs with principals that do not contain a colon (#17883)
  • PR-17898 - KAFKA-18063: SnapshotRegistry should not leak memory (#17898)
  • PR-17711 - KAFKA-17850: fix leaking internal exception in state manager (#17711)
  • PR-17713 - KAFKA-17954: Error getting oldest-iterator-open-since-ms from JMX (#17713)
  • PR-17839 - KAFKA-18029 Fix quorum_reconfiguration_test.py (#17839)
  • PR-17817 - KAFKA-17994 Checked exceptions are not handled (#17817)
  • PR-17794 - KAFKA-17995: Fix errors in remote segment cleanup when retention.ms is large (#17794)
  • PR-17799 - Update javadoc on split to mention first matching (#17799)
  • 6ea2ed3d - KAFKA-17801: RemoteLogManager may compute inaccurate upperBoundOffset for aborted txns (#17676) (#1 7733)
  • PR-17710 - KAFKA-17872: Update consumed offsets on records with invalid timestamp (#17710)
  • PR-17723 - KAFKA-17969 Fix StorageToolTest for 3.9 (#17723)
  • PR-17686 - KAFKA-17635: Ensure only committed offsets are returned for purging (#17686)
  • cc53a632 - Bump version to 3.9.0
  • PR-17683 - Removed Set.of usage (#17683)
  • PR-1510 - RCCA-23509: Modified Set.of usage in ReplicationControlManagerTest.java to resolve build failures.
  • PR-17604 - [KAFKA-17870] Fail CreateTopicsRequest if total number of partitions exceeds 10k (#17604)
  • PR-17597 - KAFKA-17868: Do not ignore –feature flag in kafka-storage.sh (#17597)
  • PR-1498 - [MINOR]: Fix version check in util.py
  • 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-1452 - Bump commonsIo to version 2.16.0
  • 5989c2b1 - Revert “KAFKA-17520 align the low bound of ducktape version (#17481)”
  • 86380a21 - Revert “KAFKA-17520 Align ducktape version in tests/docker/Dockerfile and tests/setup.py (#17482)”
  • 71839deb - KBROKER-295: Ignore failing quota_test
  • 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
  • 0bc10f33 - KBROKER-295: Ignore failing quota_test
  • PR-17508 - KAFKA-17193: Pin all external GitHub Actions to the specific git hash (#16960) (#17461) (#17508)
  • PR-1438 - KNET-15450: disable flakey test
  • PR-17481 - KAFKA-17520 align the low bound of ducktape version (#17481)
  • PR-17482 - KAFKA-17520 Align ducktape version in tests/docker/Dockerfile and tests/setup.py (#17482)
  • PR-17453 - KAFKA-17753 Update protobuf and commons-io dependencies (#17453)
  • PR-17461 - KAFKA-17193: Pin all external GitHub Actions to the specific git hash (#16960) (#17461)
  • 44f15cc2 - KAFKA-17749: Fix Throttler metrics name
  • 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-17421 - KAFKA-17735: release.py must not use home.apache.org (#17421)
  • PR-17436 - KAFKA-17753: Update protobuf and commons-io dependencies (#17436)
  • PR-17434 - KAFKA-17751; fix pollTimeout calculation in pollFollowerAsVoter (#17434)
  • PR-17400 - KAFKA-17714 Fix StorageToolTest.scala to compile under Scala 2.12 (#17400)
  • PR-16770 - KAFKA-17146 Include note to remove migration znode (#16770)
  • PR-17363 - KAFKA-16927; Handle expanding leader endpoints (#17363)
  • PR-17359 - KAFKA-17062: handle dangling “copy_segment_start” state when deleting… (#17359)
  • 596bb90c - Bump protobuf to 3.25.5
  • PR-1438 - KNET-15450: disable flakey test
  • PR-17305 - KAFKA-17636 Fix missing SCRAM bootstrap records (#17305)
  • 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-17278 - KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations (#17258) (#17278)
  • PR-17258 - KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations (#17258)
  • PR-16337 - KAFKA-16955: fix synchronization of streams threadState (#16337)
  • PR-17250 - KAFKA-17459 Stabilize reassign_partitions_test.py (#17250)
  • PR-17210 - KAFKA-17543: Improve and clarify the error message about generated broker IDs in migration (#17210)
  • PR-17218 - Revert “KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#16295)” (#17218)
  • PR-17192 - KAFKA-17543: Enforce that broker.id.generation.enable is not used when migrating to KRaft (#17192)
  • PR-17169 - KAFKA-17527: Fix NPE for null RecordContext (#17169)
  • PR-17159 - KAFKA-16468: verify that migrating brokers provide their inter.broker.listener (#17159)
  • PR-17115 - KAFKA-17489: Do not handle failed tasks as tasks to assign (#17115)
  • PR-17147 - KAFKA-17506 KRaftMigrationDriver initialization race (#17147)
  • 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-17131 - KAFKA-17497 Add e2e for zk migration with old controller (#17131)
  • PR-17101 - KAFKA-17417 Backport KAFKA-15751 and KAFKA-15752 to 3.8 and Enable KRaft for BaseAdminIntegrationTest and SaslSslAdminIntegrationTest (#15175) (#17101)
  • PR-17119 - KAFKA-17457 Don’t allow ZK migration to start without transactions (#17094) (#17119)
  • 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-17054 - KAFKA-16448: Add timestamp to error handler context (#17054)
  • PR-17067 - KAFKA-17454 Fix failed transactions_mixed_versions_test.py when running with 3.2 (#17067)
  • PR-17051 - KAFKA-17412: add doc for unclean.leader.election.enable in KRaft (#17051)
  • PR-16873 - KAFKA-17331 Throw unsupported version exception if the server does NOT support EarliestLocalSpec and LatestTieredSpec (#16873)
  • PR-17024 - KAFKA-17434: Do not test impossible scenarios in upgrade_test.py (#17024)
  • PR-16959 - KAFKA-17062: handle dangling “copy_segment_start” state when deleting remote logs (#16959)
  • 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-16990 - KAFKA-17335 Lack of default for URL encoding configuration for OAuth causes NPE (#16990)
  • PR-17012 - KAFKA-17422: Adding copySegmentLatch countdown after expiration task is over (#17012)
  • PR-16995 - KAFKA-17360 local log retention ms/bytes “-2” is not treated correctly (#16995)
  • 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-16858 - KAFKA-17315 Fix the behavior of delegation tokens that expire immediately upon creation in KRaft mode (#16858)
  • PR-16893 - KAFKA-17336 Add IT to make sure the production MV does not use unstable version of LIST_OFFSET (#16893)
  • PR-16848 - KAFKA-17305; Check broker registrations for missing features (#16848)
  • PR-16900 - KAFKA-17333; ResignedState should not notify of leader change (#16900)
  • PR-16934 - KAFKA-17279: Handle retriable errors from offset fetches (#16826) (#16934)
  • PR-16659 - KAFKA-17169: Add EndpointsTest (#16659)
  • PR-16907 - KAFKA-17332; Controller always flush and can call resign on observers (#16907)
  • PR-16892 - KAFKA-16842; Fix config validation and support unknown voters (#16892)
  • PR-16775 - KAFKA-17238 Move VoterSet and ReplicaKey from raft.internals to raft (#16775)
  • 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-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-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-16856 - KAFKA-17310 locking the offline dir can destroy the broker exceptionally (#16856)
  • PR-16820 - KAFKA-17067; Fix KRaft transition to CandidateState (#16820)
  • PR-16837 - KAFKA-16534; Implement 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 encountering UnsupportedVersionException will cause ConcurrentModificationException (#16753)
  • PR-16830 - KAFKA-16521: Have Raft endpoints printed as name://host:port (#16830)
  • 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-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-16709 - KAFKA-16584: Make log processing summary configurable or debug–update upgrade-guide (#16709)
  • PR-16811 - KAFKA-17227: Refactor compression code to only load codecs when used (#16782) (#16811)
  • 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)
  • 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-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-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-16287 - KAFKA-16934: Clean up and refactor release.py (#16287)
  • PR-16689 - KAFKA-16666 Migrate OffsetMessageFormatter to tools module (#16689)
  • PR-16675 - KAFKA-16448: Handle fatal user exception during processing error (#16675)
  • 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
  • PR-16711 - KAFKA-17210: Broker fixes for smooth concurrent fetches on share partition (#16711)
  • PR-16637 - KAFKA-16953; Properly implement the sending of DescribeQuorumResponse (#16637)
  • PR-16702 - KAFKA-17202 surround consumer with try-resource statement (#16702)
  • PR-16599 - KAFKA-14569: Migrate Connect’s integration test EmbeddedKafkaCluster from ZK to KRaft mode (#16599)
  • PR-16683 - KAFKA-17060 Rename LegacyKafkaConsumer to ClassicKafkaConsumer (#16683)
  • PR-16682 - KAFKA-17194 Don’t create cluster for MetadataQuorumCommandTest#testCommandConfig (#16682)
  • PR-16674 - KAFKA-17177 reviewers.py should grep “authors” to offer more candidates of reviewers information (#16674)
  • PR-16668 - KAFKA-16915; LeaderChangeMessage supports directory id (#16668)
  • PR-16670 - KAKFA-16537; Implement remove voter RPC (#16670)
  • PR-16183 - KAFKA-16192: Introduce transaction.version and usage of flexible records to coordinators (#16183)
  • PR-16692 - KAFKA-17204: KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient (#16692)
  • PR-16663 - KAFKA-16448: Fix processing exception handler (#16663)
  • PR-16373 - KAFKA-16558: Implemented HeartbeatRequestState toStringBase() and added a test for it (#16373)
  • PR-16688 - KAFKA-17195 remove generated code path from test scope of sourceSets (#16688)
  • PR-16671 - KAFKA-17176 Move FileLock to server-common module (#16671)
  • PR-16200 - KAFKA-15999 Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder (#16200)
  • PR-16576 - KAFKA-16765: Close leaked accepted sockets in EchoServer, NioEchoServer, ServerShutdownTest (#16576)
  • PR-16019 - KAFKA-16666 Migrate TransactionLogMessageFormatter to tools module (#16019)
  • PR-16500 - KAFKA-17021 Migrate AclCommandTest to new test infra (#16500)
  • PR-16639 - KAFKA-17160 Determine mockitoArtifactName based on mockitoVersion instead of JavaVersion (#16639)
  • PR-16656 - KAFKA-17179 Remove integration tag in class level when using ClusterTestExtensions (#16656)
  • PR-16558 - KAFKA-17104 InvalidMessageCrcRecordsPerSec is not updated in validating LegacyRecord (#16558)
  • PR-16657 - KAFKA-17168 Remove the logPrefix to print the thread name (#16657)
  • PR-16638 - KAFKA-17163 revisit testSubscriptionOnInvalidTopic and testPollAuthenticationFailure (#16638)
  • PR-16509 - KAFKA-16584 Make log processing summary configurable or debug (#16509)
  • PR-16647 - KAFKA-16068: Use TestPlugins mechanism in ConnectorValidationIntegrationTest to prevent ERROR-level log spam in unrelated test suites (#16647)
  • PR-16645 - KAFKA-17149 Move ProducerStateManagerTest to storage module (#16645)
  • 771b9576 - Bump version to 3.8.0
  • PR-16499 - KAFKA-16791 Add thread detection to ClusterTestExtensions (#16499)
  • 9db5c248 - KAFKA-16535; Implement KRaft add voter handling
  • PR-16633 - KAFKA-17159 Make sure kafka-cluster-test-kit-executor get down when closing KafkaClusterTestKit (#16633)
  • PR-16641 - KAFKA-17166 Use NoOpScheduler to rewrite LogManagerTest#testLogRecoveryMetrics (#16641)
  • PR-16614 - KAFKA-17142 Fix deadlock caused by LogManagerTest#testLogRecoveryMetrics (#16614)
  • PR-16642 - KAFKA-17168 The logPrefix of RemoteLogReader/RemoteStorageThreadPool is not propagated correctly (#16642)
  • PR-16601 - KAFKA-17082 replace kafka.utils.LogCaptureAppender with org.apache.kafka.common.utils.LogCaptureAppender (#16601)
  • PR-16618 - KAFKA-17153 KafkaMetricsGroup#newGauge should accept functional interface instead of com.yammer.metrics.core.Gague (#16618)
  • PR-16635 - KAFKA-17144 Retract unimplemented ListGroups v6 added in error (#16635)
  • PR-16609 - KAFKA-17152 Make sure zk session tracker gets down when closing embedded zk (#16609)
  • PR-16640 - KAFKA-17172 Add @Tag(“integration”) to ClusterTest, ClusterTemplate, and ClusterTests (#16640)
  • PR-16587 - KAFKA-17132 Revisit testMissingOffsetNoResetPolicy for AsyncConsumer (#16587)
  • PR-16624 - KAFKA-17121 junit-platform.properties files in published artifacts pollute the test classpath of consumers (#16624)
  • PR-16093 - KAFKA-16448: Catch and handle processing exceptions (#16093)
  • PR-16569 - KAFKA-16984: Complete consumer leave on response to leave request (#16569)
  • PR-16623 - KAFKA-17095 Fix the typo from “CreateableTopicConfig” to “CreatableTopicConfig” (#16623)
  • PR-16540 - KAFKA-17077 The node.id is inconsistent to broker.id when “broker.id.generation.enable=true”. (#16540)
  • PR-16590 - KAFKA-17122 Change the type of clusterId from UUID to String (#16590)
  • PR-16622 - KAFKA-17118 remove useless code in StorageTool (#16622)
  • PR-16372 - KAFKA-16975 The error message of creating __cluster_metadata should NOT be “Authorization failed” (#16372)
  • PR-16543 - KAFKA-15773 Group protocol configuration should be validated (#16543)
  • PR-16603 - KAFKA-17135 Add unit test for ProducerStateManager#readSnapshot and ProducerStateManager#writeSnapshot (#16603)
  • PR-16612 - KAFKA-17141 ‘DescribeTopicPartitions API is not supported’ warning message confuses users (#16612)
  • PR-16617 - KAFKA-17148: Remove print MetaPropertiesEnsemble from kafka-storage tool (#16607) (3.8) (#16617)
  • PR-16608 - KAFKA-17150: Use Utils.loadClass instead of Class.forName to resolve aliases correctly (#16608)
  • PR-16581 - KAFKA-17105: Prevent redundant restarts for newly-created connectors (#16581)
  • PR-16607 - KAFKA-17148: Remove print MetaPropertiesEnsemble from kafka-storage tool (#16607)
  • PR-16502 - KAFKA-16853: Split RemoteLogManagerScheduledThreadPool (#16502)
  • PR-16598 - KAFKA-16383: Ensure tasks have already polled their consumers before producing verified records in MirrorConnectorsIntegrationBaseTest::testReplicateFromLatest (#16598)
  • PR-16449 - KAFKA-17017 AsyncKafkaConsumer#unsubscribe clean the assigned partitions (#16449)
  • PR-16451 - KAFKA-16943: Synchronously verify Connect worker startup failure in InternalTopicsIntegrationTest (#16451)
  • PR-16230 - KAFKA-16772: Introduce kraft.version to support KIP-853 (#16230)
  • e1bf1552 - KAFKA-17055; Use random replica ids in kraft protocol tests
  • PR-16461 - KAFKA-16730: Initial version of share group consumer client code (#16461)
  • PR-16588 - KAFKA-17133 add unit test to make sure ConsumerRecords#recoreds returns immutable object (#16588)
  • PR-16572 - KAFKA-17073 Deprecate ReplicaVerificationTool (#16572)
  • PR-14372 - KAFKA-14401: Fail kafka log read end requests if underneath work thread fails (#14372)
  • PR-16557 - KAFKA-17102 FetchRequest#forgottenTopics would return incorrect data (#16557)
  • PR-16574 - KAFKA-16743,KAFKA-16744: KafkaApis support for share group heartbeat and describe (#16574)
  • PR-15918 - KAFKA-16667 Avoid stale read in KRaftMigrationDriver (#15918)
  • PR-16573 - KAFKA-16741: Add ShareGroupHeartbeat API support - 2/N (KIP-932) (#16573)
  • PR-16571 - KAFKA-17097 Add replace.null.with.default configuration to ValueToKey and ReplaceField (#16571)
  • PR-16221 - KAFKA-16661: Added a lower log.initial.task.delay.ms value (#16221)
  • PR-16249 - KAFKA-16916: Fixing error in completing future (#16249)
  • PR-16217 - KAFKA-16905: Fix blocking DescribeCluster call in AdminClient DescribeTopics (#16217)
  • PR-16589 - KAFKA-17129 Revisit FindCoordinatorResponse in KafkaConsumerTest (#16589)
  • PR-16566 - KAFKA-17110 Enable valid test case in KafkaConsumerTest for AsyncKafkaConsumer (#16566)
  • PR-16564 - KAFKA-17106 enable testFetchProgressWithMissingPartitionPosition for AsyncConsumer (#16564)
  • PR-16518 - KAFKA-16532; Support for first leader bootstrapping the voter set (#16518)
  • PR-16559 - KAFKA-17096 Fix kafka_log4j_appender.py (#16559)
  • PR-16529 - KAFKA-17061 Improve the performance of isReplicaOnline (#16529)
  • PR-16541 - KAFKA-17092 Revisit KafkaConsumerTest#testBeginningOffsetsTimeout for AsyncConsumer (#16541)
  • PR-16570 - KAFKA-17098: Re-add task to state updater if transit to RUNNING fails (#16570)
  • PR-16565 - KAFKA-17111: explicitly register Afterburner module in JsonSerializer and JsonDeserializer (#16565)
  • PR-16561 - KAFKA-17085: Handle tasks in state updater before tasks in task registry (#16555) (#16561)
  • PR-16421 - KAFKA-17011: Fix a bug preventing features from supporting v0 (#16421)
  • PR-16506 - KAFKA-15853 Refactor ShareGroupConfig with AbstractConfig (#16506)
  • PR-16539 - KAFKA-17090 Add reminder to CreateTopicsResult#config for null values of type and documentation (#16539)
  • PR-16426 - KAFKA-17016 Align the behavior of GaugeWrapper and MeterWrapper (#16426)
  • PR-16555 - KAFKA-17085: Handle tasks in state updater before tasks in task registry (#16555)
  • PR-16475 - KAFKA-16228: Add remote log metadata flag to the dump log tool (#16475)
  • PR-16132 - KAFKA-16851: Add remote.log.disable.policy (#16132)
  • PR-15475 - KAFKA-16345: Optionally URL-encode clientID and clientSecret in authorization header (#15475)
  • PR-16532 - KAFKA-16684: Remove caching in FetchResponse.responseData (#16532)
  • PR-15999 - KAFKA-16254: Allow MM2 to fully disable offset sync feature (#15999)
  • PR-16530 - KAFKA-17071: SharePartition - Add more unit tests and minor enhancement (#16530)
  • PR-1398 - fixed downstream trigger
  • PR-16550 - KAFKA-10199: Close pending active tasks to init on partitions lost (#16545) (#16550)
  • PR-1394 - 3.8 fixed downstream trigger
  • PR-15756 - KAFKA-15838: KIP-1040: Add replace.null.with.default to InsertField, ExtractField, HeaderFrom, Cast, SetSchemaMetadata, TimestampConverter, MaskField transforms (#15756)
  • PR-16545 - KAFKA-10199: Close pending active tasks to init on partitions lost (#16545)
  • PR-16524 - KAFKA-17081 Tweak GroupCoordinatorConfig: re-introduce local attributes and validation (#16524)
  • PR-16488 - KAFKA-16731: Added share group metrics class. (#16488)
  • PR-11438 - KAFKA-13403 Fix broker crash due to race condition when deleting topics (#11438)
  • PR-16301 - KAFKA-16806 Explicitly declare JUnit dependencies for all test modules (#16301)
  • PR-16533 - KAFKA-17083: Update LATEST_STABLE_METADATA_VERSION in system tests (#16533)
  • PR-1413 - Update service.yml to use strings instead of floats for branches
  • PR-16508 - KAFKA-4374 Update log message for clarity metadata response errors (#16508)
  • PR-16523 - KAFKA-17059 Remove dynamicConfigOverride from KafkaConfig (#16523)
  • PR-16526 - Fix compilation error (#16526)
  • PR-16504 - KAFKA-16944; Rewrite Range Assignor (#16504)
  • PR-16516 - KAFKA-16741: Add share group classes for Heartbeat API (1/N) (KIP-932) (#16516)
  • PR-16498 - KAFKA-17058; Extend CoordinatorRuntime to support non-atomic writes (#16498)
  • PR-16086 - KAFKA-17069: Remote log copy throttle metrics (#16086)
  • PR-16454 - KAFKA-16529; Implement raft response handling (#16454)
  • PR-16477 - KAFKA-10816: Add health check endpoint for Kafka Connect (#16477)
  • PR-16513 - KAFKA-16754: Removing partitions from release API (KIP-932) (#16513)
  • PR-15302 - KAFKA-15917: Wait for zombie sink tasks’ consumers to commit offsets before trying to modify their offsets in integration tests (#15302)
  • PR-16459 - KAFKA-17026: Implement updateCacheAndOffsets functionality on LSO movement (#16459)
  • PR-16515 - Update License binary file with missing updates (#16515)
  • PR-16087 - KAFKA-15265: Remote fetch throttle metrics (#16087)
  • PR-16474 - KAFKA-17047: Refactored group coordinator classes to modern package (KIP-932) (#16474)
  • PR-16460 - KAFKA-17032 NioEchoServer should generate meaningful id instead of incremental number (#16460)
  • PR-16485 - KAFKA-16550 add integration test for LogDirsCommand (#16485)
  • PR-16480 - KAFKA-17051 ApiKeys#toHtml should exclude the APIs having unstable latest version (#16480)
  • PR-16403 - KAFKA-3346 Rename Mode to ConnectionMode (#16403)
  • PR-16400 - Revert “KAFKA-16154” and mark MV 3.8-IV0 as the latest production (#16400)
  • PR-1359 - [master] removes mk-include
  • PR-1368 - 3.8 removed mk-include and make init-ci from semaphore
  • PR-16457 - KAFKA-16750: Added acknowledge code in SharePartitionManager including unit tests (#16457)
  • PR-16482 - KAFKA-17050: Revert group.version (#16482)
  • PR-15224 - KAFKA-15727: Added KRaft support in AlterUserScramCredentialsRequestNotAuthorizedTest (#15224)
  • PR-16458 - KAFKA-16909 Refactor GroupCoordinatorConfig with AbstractConfig (#16458)
  • PR-16469 - KAFKA-17046 Upgrade netty version to 4.1.111.Final (#16469)
  • PR-16450 - KAFKA-16508: Streams custom handler should handle the timeout exceptions (#16450)
  • PR-16489 - KAFKA-17052: Downgrade ShadowJarPlugin to 8.1.3 (#16489)
  • PR-16478 - KAFKA-17050: Revert group.version from 3.8 (#16478)
  • PR-1351 - CONFLUENT: Downgrade io.github.goooler.shadow plugin to 8.1.3
  • PR-16312 - KAFKA-16000: Migrated MembershipManagerImplTest away from ConsumerTestBuilder (#16312)
  • PR-16399 - KAFKA-16536; Use BeginQuorumEpoch as leader heartbeat (#16399)
  • PR-16455 - KAFKA-17022 Fix error-prone in KafkaApis#handleFetchRequest (#16455)
  • ebaa1089 - KAFKA-16968: Introduce 3.8-IV0, 3.9-IV0, 3.9-IV1
  • PR-1346 - fixed RAT on CI builds
  • PR-16467 - KAFKA-10787 Apply spotless to all module (#16467)
  • PR-16054 - KAFKA-16822: Abstract consumer group to share functionality with share group (KIP-932) (#16054)
  • PR-16430 - KAFKA-16754: Implemented release acquired records functionality to SharePartition (#16430)
  • PR-16447 - KAFKA-15623 Remove junit 4 from stream module (#16447)
  • PR-16446 - KAFKA-16751: Implemented release acquired records functionality in SharePartitionManager (#16446)
  • PR-16431 - KAFKA-17003: Implemented SharePartitionManager close() functionality (#16431)
  • PR-16235 - KAFKA-16527; Implement request handling for updated KRaft RPCs (#16235)
  • PR-16448 - KAFKA-17034 Tweak some descriptions in FeatureUpdate (#16448)
  • PR-16441 - Revert “KAFKA-16275: Update kraft_upgrade_test.py to support KIP-848’s group protocol config (#16409) (#16441)
  • PR-15915 - KAFKA-16949: Fixing test_dynamic_logging in system test connect_distributed_test (#15915)
  • PR-16439 - KAFKA-16551 add integration test with bootstrap controller for ClusterTool (#16439)
  • PR-16440 - KAFKA-17028: FindCoordinator v6 initial implementation (#16440)
  • PR-16429 - KAFKA-16650 add integration test for Admin#abortTransaction (#16429)
  • PR-16257 - KAFKA-16855 : Part 1 - New fields tieredEpoch and tieredState (#16257)
  • PR-16424 - KAFKA-15623 (5/N) Migrate KafkaStreamsTest to JUnit 5 (#16424)
  • PR-16414 - KAFKA-16755: Implement lock timeout functionality in SharePartition (#16414)
  • PR-16344 - KAFKA-16965: Throw cause of TimeoutException (#16344)
  • PR-16413 - KAFKA-17013 RequestManager#ConnectionState#toString() should use %s (#16413)
  • PR-16408 - KAFKA-16551 add integration test for ClusterTool (#16408)
  • PR-16396 - KAFKA-15623 (4/N) Migrate streams tests (processor) module to JUnit 5 (#16396)
  • PR-16410 - KAFKA-16998 Fix warnings in our Github actions (#16410)
  • PR-16423 - KAFKA-17009 Add unit test to query nonexistent replica by describeReplicaLogDirs (#16423)
  • PR-15830 - KAFKA-15713 KRaft support in AclCommandTest (#15830)
  • PR-1312 - skipped build, compile, validations in public CI
  • PR-16409 - Revert “KAFKA-16275: Update kraft_upgrade_test.py to support KIP-848’s group protocol config (#16409)
  • PR-16377 - KAFKA-16749: Implemented share fetch messages (KIP-932) (#16377)
  • PR-16415 - KAFKA-17012 Enable CONSUMER protocol for some tests of KafkaConsumerTest (#16415)
  • PR-16416 - KAFKA-17007 Fix SourceAndTarget#equal (#16416)
  • PR-16397 - KAFKA-16999: Integrating persister API in Partition initialization (KIP-932) (#16397)
  • PR-16412 - KAFKA-10787 apply spotless to connect:runtime module (#16412)
  • PR-16211 - KAFKA-16531: calculate check-quorum when leader is not in voter set (#16211)
  • PR-16303 - KAFKA-16862: Refactor ConsumerTaskTest to be deterministic and avoid tight loops (#16303)
  • PR-16295 - KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#16295)
  • PR-16356 - KAFKA-15623 (3/N) Migrate test of Stream module to Junit5 (Stream state) (#16356)
  • PR-16259 - KAFKA-16923 New Unit Test for stripDotPathComponents method (#16259)
  • PR-16401 - KAFKA-17000 Separating creation and configuration of Authorizer in AuthorizerTest (#16401)
  • PR-16394 - KAFKA-16976 Update the current/dynamic config inside RemoteLogManagerConfig (#16394)
  • PR-16393 - KAFKA-10787 Apply spotless to clients module (#16393)
  • PR-1308 - do not depend on vault on public CI
  • PR-16367 - KAFKA-16973; Fix caught-up condition (#16367)
  • PR-16317 - KAFKA-16939 Revisit ConfigCommandIntegrationTest (#16317)
  • PR-16360 - KAFKA-15623 (2/N) Migrate remaining tests in streams module to JUnit 5 (integration & internals) (#16360)
  • PR-1303 - removed vault secrets
  • PR-16368 - KAFKA-16725: Adjust share group configs to match KIP (#16368)
  • PR-16380 - KAFKA-15774: use the default dsl store supplier for fkj subscriptions (#16380)
  • PR-16383 - KAFKA-16921 [6/N] Remove junit 4 dependency from connect:runtime module (#16383)
  • PR-16392 - KAFKA-10787 Apply spotless to core module (#16392)
  • PR-16370 - KAFKA-16957 Enable KafkaConsumerTest#configurableObjectsShouldSeeGeneratedClientId to work with CLASSIC and CONSUMER (#16370)
  • PR-16385 - KAFKA-16989 Use StringBuilder instead of String concatenation (#16385)
  • PR-16339 - KAFKA-16753: Implement share acknowledge API in partition (KIP-932) (#16339)
  • PR-16333 - KAFKA-16952: Do not bump broker epoch when re-registering the same incarnation (#16333)
  • PR-16379 - KAFKA-16988: add 1 more node for test_exactly_once_source system test (#16379)
  • PR-16378 - KAFKA-10787 apply spotless to streams:examples and streams-scala (#16378)
  • PR-16348 - KAFKA-16958 add STRICT_STUBS to EndToEndLatencyTest, OffsetCommitCallbackInvokerTest, ProducerPerformanceTest, and TopologyTest (#16348)
  • PR-16355 - KAFKA-16547 Add test for DescribeConfigsOptions#includeDocumentation (#16355)
  • PR-16350 - KAFKA-16921 [5/N] Migrate test of connect module to Junit5 (Runtime subpackage) (#16350)
  • PR-16351 - KAFKA-16921 [4/N] Migrate test of connect module to Junit5 (Runtime direct) (#16351)
  • PR-16376 - KAFKA-16954: fix consumer close to release assignment in background (#16376)
  • PR-16353 - KAFKA-15265: Reapply dynamic remote configs after broker restart (#16353)
  • PR-16366 - KAFKA-16969: Log error if config conflicts with MV (#16366)
  • PR-16369 - [MINOR] Add a note for JBOD support for tiered storage (#16369)
  • PR-16343 - KAFKA-16954: fix consumer close to release assignment in background (#16343)
  • PR-15175 - KAFKA-15751, KAFKA-15752: Enable KRaft for BaseAdminIntegrationTest and SaslSslAdminIntegrationTest (#15175)
  • PR-16359 - KAFKA-16970 Fix hash implementation of ScramCredentialValue, ScramCredentialData, and ContextualRecord (#16359)
  • PR-16357 - KAFKA-10787 Apply spotless to stream:test-utils and :streams:upgrade-system-tests-xxxx (#16357)
  • PR-16309 - KAFKA-16673; Simplify GroupMetadataManager#toTopicPartitions by using ConsumerProtocolSubscription instead of ConsumerPartitionAssignor.Subscription (#16309)
  • PR-15924 - KAFKA-16669 Remove extra collection copy when generating DescribeAclsResource (#15924)
  • PR-16354 - KAFKA-16219 set SO_TIMEOUT in EchoServer (#16354)
  • PR-16280 - KAFKA-10190 Set dynamic broker configs for entity default (#16280)
  • PR-16341 - KAFKA-16898 move TimeIndexTest and TransactionIndexTest to storage module (#16341)
  • PR-16358 - KAFKA-16971 Fix the incorrect format string in QuorumConfigs#parseBootstrapServer (#16358)
  • PR-16338 - KAFKA-16932: Add documentation for the native docker image (#16338)
  • PR-16297 - KAFKA-10787 Apply spotless to metadata and server and storage module (#16297)
  • PR-16335 - KAFKA-16950: Define Persister interfaces and RPCs (#16335)
  • PR-16340 - KAFKA-16740: Added additional APIs for Share Partition (#16340)
  • PR-15986 - Revert new configurations from KAFKA-16525; Dynamic KRaft network manager and channel (#15986)
  • PR-16278 - KAFKA-10787 Apply spotless to raft module (#16278)
  • c29260f3 - Revert “KAFKA-16535: Implement AddVoter, RemoveVoter, UpdateVoter RPCs”
  • PR-16210 - KAFKA-16895 fix off-by-one bug in RemoteCopyLagSegments (#16210)
  • PR-16310 - KAFKA-16637 AsyncKafkaConsumer removes offset fetch responses from cache too aggressively (#16310)
  • PR-16319 - KAFKA-16946: Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:port (#16319)
  • PR-16330 - KAFKA-16921 [3/N] migrate connect module to junit 5 (#16330)
  • PR-16328 - KAFKA-16921 [2/N] migrate connect module to junit 5 (#16328)
  • PR-16250 - KAFKA-16917 DescribeTopicsResult should use mutable map in order to keep compatibility (#16250)
  • PR-16116 - KAFKA-15853: Move KafkaConfig.configDef out of core (#16116)
  • PR-16263 - KAFKA-16747: Implemented share sessions and contexts for share fetch requests (#16263)
  • PR-16272 - KAFKA-16933: New consumer unsubscribe close commit fixes (#16272)
  • PR-16321 - KAFKA-16948: Reset tier lag metrics on becoming follower (#16321)
  • PR-16231 - KAFKA-12708 Rewrite org.apache.kafka.test.Microbenchmarks by JMH (#16231)
  • PR-16331 - KAFKA-15045: (KIP-924 pt. 26) default standby task assignment nit (#16331)
  • PR-16274 - KAFKA-16752: Implemented acquire functionality for Fetch (KIP-932) (#16274)
  • PR-16254 - KAFKA-15623 (1/N) Migrate streams tests module to JUnit 5 (#16254)
  • PR-16298 - KAFKA-10787 Apply spotless to group-coordinator and group-coordinator-api (#16298)
  • PR-16266 - KAFKA-16879 SystemTime should use singleton mode (#16266)
  • PR-16282 - KAFKA-16076 Fix Missing thread interrupt call in RestClient class (#16282)
  • PR-16140 - KAFKA-16001: Migrated ConsumerNetworkThreadTest away from ConsumerTestBuilder (#16140)
  • PR-16322 - KAFKA-15045: (KIP-924 pt. 25) Rename old internal StickyTaskAssignor to LegacyStickyTaskAssignor (#16322)
  • PR-16253 - KAFKA-16921 [1/N] Migrate all junit 4 code to junit 5 for connect module (#16253)
  • PR-15890 - KAFKA-16643 Add ModifierOrder checkstyle rule (#15890)
  • PR-16318 - KAFKA-15045: (KIP-924 pt. 24) internal TaskAssignor rename to LegacyTaskAssignor (#16318)
  • PR-16291 - KAFKA-16557 Implemented OffsetFetchRequestState toStringBase and added a test for it (#16291)
  • PR-16227 - KAFKA-16901 Add unit tests for ConsumerRecords#records(String) (#16227)
  • PR-16302 - KAFKA-16938 non-dynamic props gets corrupted due to circular reference between DynamicBrokerConfig and DynamicConfig. (#16302)
  • PR-16237 - KAFKA-16890: Compute valid log-start-offset when deleting overlapping remote segments (#16237)
  • PR-16288 - KAFKA-16935: Automatically wait for cluster startup in embedded Connect integration tests (#16288)
  • PR-16244 - KAFKA-16897 Move OffsetIndexTest and OffsetMapTest to storage module (#16244)
  • PR-16292 - KAFKA-15045: (KIP-924 pt. 23) More TaskAssignmentUtils tests (#16292)
  • PR-13277 - KAFKA-8206: KIP-899: Allow client to rebootstrap (#13277)
  • PR-16229 - KAFKA-16570 FenceProducers API returns “unexpected error” when succes… (#16229)
  • PR-16136 - KAFKA-16865: Add IncludeTopicAuthorizedOperations option for DescribeTopicPartitionsRequest (#16136)
  • PR-16296 - KAFKA-10787 Apply spotless to log4j-appender, trogdor, jmh-benchmarks, examples, shell and generator (#16296)
  • PR-16078 - KAFKA-15265: Dynamic broker configs for remote fetch/copy quotas (#16078)
  • PR-16299 - KAFKA-10787 Apply spotless to connect module (#16299)
  • PR-16215 - KAFKA-16770; [2/2] Coalesce records into bigger batches (#16215)
  • PR-16107 - KAFKA-10199: Enable state updater by default (#16107)
  • PR-16294 - KAFKA-15045: (KIP-924 pt. 22) Add RackAwareOptimizationParams and other minor TaskAssignmentUtils changes (#16294)
  • PR-16255 - KAFKA-16922 Adding unit tests for NewTopic (#16255)
  • PR-15820 - KAFKA-15265: Integrate RLMQuotaManager for throttling copies to remote storage (#15820)
  • PR-15993 - KAFKA-16541 Fix potential leader-epoch checkpoint file corruption (#15993)
  • PR-16269 - KAFKA-15045: (KIP-924 pt. 21) UUID to ProcessId migration (#16269)
  • PR-16283 - KAFKA-16930; UniformHeterogeneousAssignmentBuilder throws NPE when one member has no subscriptions (#16283)
  • PR-16106 - KAFKA-16520: Support KIP-853 in DescribeQuorum (#16106)
  • PR-16209 - KAFKA-16904: Metric to measure the latency of remote read requests (#16209)
  • PR-16281 - KAFKA-16373: KIP-1028: Modifying download url for kafka dockerfile (#16281)
  • PR-16267 - KAFKA-16373: KIP-1028: Adding 3.7.0 docker official images static assets (#16267)
  • PR-16268 - KAFKA-16914: Added share group dynamic and broker configs (#16268)
  • PR-16203 - KAFKA-15776: Support added to update remote.fetch.max.wait.ms dynamically (#16203)
  • PR-16256 - KAFKA-16885 Renamed the enableRemoteStorageSystem to isRemoteStorageSystemEnabled (#16256)
  • PR-16199 - KAFKA-16884 Refactor RemoteLogManagerConfig with AbstractConfig (#16199)
  • PR-14778 - KAFKA-15776: Introduce remote.fetch.max.timeout.ms to configure DelayedRemoteFetch timeout (#14778)
  • PR-16180 - KAFKA-16882 Migrate RemoteLogSegmentLifecycleTest to ClusterInstance infra (#16180)
  • PR-16173 - KAFKA-16880 Update equals and hashcode methods for two attributes (#16173)
  • PR-16154 - KAFKA-16852 Adding two thread pools kafka-16852 (#16154)
  • PR-16153 - KAFKA-16859 Cleanup check if tiered storage is enabled (#16153)
  • PR-16170 - KAFKA-16785 Migrate TopicBasedRemoteLogMetadataManagerRestartTest to new test infra (#16170)
  • PR-16152 - KAFKA-16866 Used the right constant in RemoteLogManagerTest#testFetchQuotaManagerConfig (#16152)
  • PR-16262 - KAFKA-10787 Apply spotless to tools and tools-api module (#16262)
  • 68070c94 - KAFKA-16724: Added support for fractional throughput and monotonic payload in kafka-producer-perf-test.sh
  • PR-16260 - add slf4jlog4j in tool (#16260)
  • PR-16053 - KAFKA-9228: Restart tasks on runtime-only connector config changes (#16053)
  • PR-16043 - KAFKA-16764: New consumer should throw InvalidTopicException on poll when invalid topic in metadata. (#16043)
  • PR-16261 - [MINOR] KAFKA-16373: KIP-1028: Modifying dockerfile comments (#16261)
  • PR-16226 - modifying Readme for Docker official images (#16226)
  • PR-16158 - KAFKA-14509; [4/4] Handle includeAuthorizedOperations in ConsumerGroupDescribe API (#16158)
  • PR-16188 - KAFKA-16448: Add ProcessingExceptionHandler in Streams configuration (#16188)
  • PR-16157 - KAFKA-15718: Refactor UncleanLeaderElectionTest to enable KRaft later (#16157)
  • PR-16245 - KAFKA-15045: (KIP-924 pt. 20) Custom task assignment configuration fix (#16245)
  • PR-16201 - KAFKA-15045: (KIP-924 pt. 18) Better assignment testing (#16201)
  • PR-16252 - KAFKA-16920: close BrokerLifecycleManager in tests (#16252)
  • PR-16172 - KAFKA-10787 Apply spotless to transaction-coordinator and server-common (#16172)
  • PR-16236 - KAFKA-16878 Remove powermock and easymock from code base (#16236)
  • PR-16232 - KAFKA-16886: Detect replica demotion in AssignmentsManager (#16232)
  • PR-16248 - KAFKA-16916: Disable blocking test temporarily (#16248)
  • 7879f1c0 - KAFKA-16535: Implement AddVoter, RemoveVoter, UpdateVoter RPCs
  • PR-15869 - KAFKA-16493: Avoid unneeded subscription regex check if metadata version unchanged (#15869)
  • PR-15834 - KAFKA-16606 Gate JBOD configuration on 3.7-IV2 (#15834)
  • PR-16031 - KAFKA-16200: Enforce that RequestManager implementations respect user-provided timeout (#16031)
  • PR-16214 - KAFKA-16786: Remove old assignment strategy usage in new consumer (#16214)
  • PR-16234 - KAFKA-16912 Migrate ConsumerNetworkThreadTest.testPollResultTimer() to NetworkClientDelegateTest (#16234)
  • PR-16126 - KAFKA-16223 Migrate KafkaConfigBackingStoreTest to Mockito (#16126)
  • PR-16219 - KAFKA-15045: (KIP-924 pt. 19) Update to new AssignmentConfigs (#16219)
  • PR-16222 - KAFKA-16903: Consider produce error of different task (#16222)
  • PR-16198 - KAFKA-14701; Move PartitionAssignor to new group-coordinator-api module (#16198)
  • PR-16187 - KAFKA-16448: Add ProcessingExceptionHandler interface and implementations (#16187)
  • PR-16079 - KAFKA-16530: Fix high-watermark calculation to not assume the leader is in the voter set (#16079)
  • PR-16165 - KAFKA-16814 KRaft broker cannot startup when partition.metadata is missing (#16165)
  • PR-16194 - KAFKA-15045: (KIP-924 pt. 17) State store computation fixed (#16194)
  • PR-16147 - KAFKA-15045: (KIP-924 pt. 16) TaskAssignor.onAssignmentComputed handling (#16147)
  • PR-15689 - KAFKA-12317: Update FK-left-join documentation (#15689)
  • PR-15790 - KAFKA-16573: Specify node and store where serdes are needed (#15790)
  • PR-16161 - KAFKA-16858: Throw DataException from validateValue on array and map schemas without inner schemas (#16161)
  • PR-16071 - KAFKA-15265: Integrate RLMQuotaManager for throttling fetches from remote storage (#16071)
  • PR-16186 - KAFKA-16888 Fix failed StorageToolTest.testFormatSucceedsIfAllDirectoriesAreAvailable and StorageToolTest.testFormatEmptyDirectory (#16186)
  • PR-16176 - KAFKA-10787 Update spotless version and remove support JDK8 (#16176)
  • PR-16184 - KAFKA-16740: Adding skeleton code for Share Fetch and Acknowledge RPC (KIP-932) (#16184)
  • PR-16105 - KAFKA-16483: Remove preAppendErrors from createPutCacheCallback (#16105)
  • 9ceed8f1 - KAFKA-16535: Implement AddVoter, RemoveVoter, UpdateVoter RPCs
  • PR-16156 - KAFKA-15305 The background thread should try to process the remaining task until the shutdown timer is expired. (#16156)
  • PR-16178 - KAFKA-15852: Move LinuxIoMetricsCollector to server module (#16178)
  • PR-16118 - KAFKA-16583: Handle PartitionChangeRecord without directory IDs (#16118)
  • PR-16068 - KAFKA-16821; Member Subscription Spec Interface (#16068)
  • PR-16122 - KAFKA-16837, KAFKA-16838: Ignore task configs for deleted connectors, and compare raw task configs before publishing them (#16122)
  • PR-16151 - KAFKA-16047: Use REQUEST_TIMEOUT_MS_CONFIG in AdminClient.fenceProducers (#16151)
  • PR-16144 - KAFKA-16664; Re-add EventAccumulator.poll(long, TimeUnit) (#16144)
  • PR-16134 - KAFKA-16715: Create KafkaShareConsumer interfaces (#16134)
  • PR-15165 - KAFKA-16105: Reset read offsets when seeking to beginning in TBRLMM (#15165)
  • PR-16163 - KAFKA-16861: Don’t convert to group to classic if the size is larger than group max size. (#16163)
  • PR-16175 - KAFKA-16881: InitialState type leaks into the Connect REST API OpenAPI spec (#16175)
  • PR-16169 - KAFKA-15156 Update cipherInformation correctly in DefaultChannelMetadataRegistry (#16169)
  • PR-16022 - KAFKA-16713: Define initial set of RPCs for KIP-932 (#16022)
  • PR-16097 - KAFKA-10787 Add import ordering checkstyle rule and configure an automatic formatter (#16097)
  • PR-16164 - KAFKA-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest (#16164)
  • PR-16042 - KAFKA-16807 DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions (#16042)
  • PR-15945 - KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2 (#15945)
  • PR-15863 - KAFKA-16574 The metrics of LogCleaner disappear after reconfiguration (#15863)
  • PR-15862 - KAFKA-16652 add unit test for ClusterTemplate offering zero ClusterConfig (#15862)
  • PR-16017 - KAFKA-16639 Ensure HeartbeatRequestManager generates leave request regardless of in-flight heartbeats. (#16017)
  • PR-16088 - KAFKA-16864; Optimize uniform (homogenous) assignor (#16088)
  • PR-16149 - KAFKA-16860; [2/2] Introduce group.version feature flag (#16149)
  • PR-16120 - KAFKA-16860; [1/2] Introduce group.version feature flag (#16120)
  • PR-16025 - KAFKA-16809: Run Javadoc in CI (#16025)
  • PR-15840 - KAFKA-16629 Add broker-related tests to ConfigCommandIntegrationTest (#15840)

ksqlDB

  • 4354d07a - unpin jetty
  • PR-10635 - Added Warn Logger for Orphan Topics (UnknownTopicOrPartitionException) & for Command Topic Size exceeding threshold
  • PR-10614 - Merge Conflict Resolution (from 7.3.x to 7.4.x)
  • PR-10612 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
  • PR-10608 - Fix close query context error
  • PR-10610 - Merge Conflict Resolution (from 7.3.x to 7.4.x)
  • PR-10607 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
  • PR-10601 - Optimize Latency in POST /ksql API for describe streams Due to Orphan Topics
  • PR-10602 - adding cp-jar-build semaphoreCI block
  • 355538b3 - Add OAuth Support in KSQL CLI
  • PR-10581 - Merge Conflict Fix and Build
  • PR-10578 - fix: for dependency update for jsonschema
  • PR-10551 - feat: add error log for logging topic client errors
  • PR-10506 - Fix the argument list for HttpAccessTokenRetriever.
  • PR-10503 - Fix classloader after connect starts
  • PR-10482 - Updated the args as per changes in kafka
  • PR-10478 - Update netty version from 4.1.108.Final to 4.1.113.Final.
  • PR-10481 - Fix for Arg Count Mismatch
  • bb335fa1 - nit
  • PR-157 - Remove KSQL internal topics from the list topic results. Sort the top
  • PR-156 - improve test coverage for cli
  • PR-10468 - adding PR CI gating config in service.yml for cc-service-bot to enable cp jar build
  • 10d04ca5 - Change configType to PASSWORD
  • 3213368f - Update netty version from 4.1.108.final to 1.1.113.Final.
  • 58125e73 - address reviews
  • f5c31c27 - address reviews
  • aee1218e - Update netty version from 4.1.108.Final to 4.1.113.Final.
  • 1ef32457 - Update netty version from 4.1.108.Final to 4.1.113.Final.
  • PR-132 - Proper error message when with clause is not set correctly.
  • PR-10441 - fix base_dir as / causing java.net.UnknownHostException: etc
  • PR-10414 - Added Debug Capability and Updated ReadMe

REST Proxy

  • bf7e380a - change imports to confluent package
  • a9c69e6f - unpin jetty-servlets
  • PR-515 - Add DoSFilter from Jetty 9.4.53
  • PR-1322 - Fix visibility for stopRest function
  • PR-1318 - Change to manageRest to make the name consistent for all release branch
  • PR-1311 - Allow to start kafka rest separately so that the integration test can be more customisable
  • PR-1312 - Update codeowners
  • PR-1293 - chore: update repo by service bot
  • PR-1292 - Fix build breaks due to upstream changes
  • PR-524 - Backport http2 support changes to 7.5.x
  • 02615956 - update async_http_client without upgrade of major version
  • PR-511 - Add @confluentinc/kora-networking as Codeowner
  • 48e03221 - remove the hibernate-validator exclusion no longer needed due to updated jersey-bean-validation
  • 302da1b6 - add a comment
  • c6a50d88 - Add access.control.expose.headers into the CORS filters
  • PR-12 - Added more REST exceptions
  • PR-10 - Add RestConstraintViolationException for better error codes for some constraint violations.
  • PR-491 - Add configuration hsts.header.enable to control whether we response with HSTS header

Schema Registry

  • PR-3517 - making buildConnectionProtected
  • PR-3455 - add pagination for get all subjects
  • PR-3515 - Fix equivalence checks for JSON and Protobuf
  • PR-3512 - Ensure message reader can return multiple records
  • PR-3509 - Fix handling of nested Protobuf types when generating descriptor
  • PR-3505 - Merge Conflict Resolution (from 7.8.x to 7.9.x)
  • d4c0fcd8 - Update parent POM version in new module
  • PR-3498 - Fix parent POM version in new module
  • PR-3497 - Fix parent POM version in new module
  • PR-3489 - adding cp-jar-build block for 79x
  • PR-3500 - Prevent overwriting argLine execution variable
  • e13dac33 - Update generated files
  • cd5df0be - add codeartifact paths
  • 7f75e155 - Update parent pom
  • 13d494b6 - Don’t overwrite argLine var (https://stackoverflow.com/a/23605812)
  • 749e1c9b - Merge conflicts
  • PR-3462 - Enable SonarQube reporting
  • PR-3496 - Fix parent POM version in new module
  • PR-3495 - Fix parent POM version in new module
  • PR-3494 - Fix parent POM version in new module
  • PR-3484 - Prioritize the Shutdown of the Leader Elector
  • PR-3481 - Fix retry logic for callables that return void
  • PR-3478 - Fix JSON Schema dependency
  • PR-3461 - Add test to ensure Protobuf map entry option is preserved
  • PR-3468 - Ensure json-skema validator is called if possible
  • PR-3449 - Add composite deserializer for migration use cases
  • PR-3459 - Optimization to use confluent:version if available
  • PR-3458 - Enhance lookup match to be more lenient wrt confluent:version
  • PR-3457 - Revert “Ensure map_entry option is not emitted (#3444)”
  • PR-3453 - Port AWS KMS integration code to AWS SDK v2
  • PR-3447 - Pass IP address so that requests sent to leader can forward the IP
  • PR-3444 - Ensure map_entry option is not emitted
  • PR-3441 - Added config for not waiting for kafka reader on store init and leader election
  • PR-3440 - remove pin of bouncycastle to favor version defined in common
  • PR-3437 - fix: Config for not throwing timeout exception when waiting for Kafka reader on init
  • PR-3434 - Fix transformation of fields in JSON Schema definitions
  • PR-3430 - Fix merge 7.4.x to 7.5.x
  • PR-3424 - Add retry logic to RestService
  • PR-3427 - Add config to specify packages to scan when deriving JSON Schema
  • PR-3425 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
  • PR-3394 - remove pin of bouncycastle to favor version defined in common
  • PR-3423 - Downgrade JSONata to 2.4.5
  • PR-3417 - Revert “Upgrade json-schema to 1.14.4 (#3400)”
  • PR-3415 - Fix merge issue
  • PR-3414 - Fix merge issue
  • PR-3402 - Upgrade wire to 5.1.0
  • ebf23a1d - Upgrade jsonata to 2.4.9
  • PR-3401 - Upgrade json-skema to 0.19.0
  • PR-3400 - Upgrade json-schema to 1.14.4
  • PR-3399 - Upgrade tink to 1.15
  • PR-3397 - Upgrade cel-java to 0.4.5
  • PR-3396 - Remove scala dependency for mbknor library
  • PR-3404 - Added kafka-tools dependency
  • PR-3392 - Handle schema migrations for Proto message types after first
  • PR-3393 - remove hibernate-validator exclusion and pin as the updated dependency uses new version
  • PR-3390 - More robust retries in RetryExecutor
  • PR-3391 - Return 404 instead of 429 if schema lookup fails
  • PR-3389 - Retry on 500
  • PR-3388 - Add test that uses both JSONata and CEL
  • PR-3384 - Fix javadoc annotations to have no errors
  • PR-3382 - Handle refs with version of -1 when looking up schemas
  • PR-3379 - Allow empty fragment (#) in $schema prop for JSON Schema
  • PR-3378 - Handle doubly nested CombinedSchema when getting tags
  • PR-3373 - Revert #3224 to resolve CP Packaging 7.9.x build
  • PR-3359 - Add latest caches at the SR client level
  • PR-3361 - Don’t create a new version if latest is equivalent
  • PR-3351 - Ensure InvalidSchemaException is thrown from parseSchema
  • PR-3354 - Add test to ensure MD5 does not change for schema values
  • PR-3352 - Minor optimization to reduce schema ID lookups
  • PR-3348 - Reapply “Fix race condition when getting decoder for sensitive metadata”
  • PR-3349 - Reapply “Allow SR to ignore confluent:version when matching
  • PR-3347 - Enable semaphore pipeline on sr release branch
  • PR-3346 - Include sonarqube
  • PR-3343 - Revert “Allow SR to ignore confluent:version when matching
  • PR-3342 - Revert “Fix race condition when getting decoder for sensitive metadata”
  • PR-3334 - Revert change to default rule actions
  • PR-3339 - Revert “Fix race condition when getting decoder for sensitive metadata”
  • PR-3337 - Fix pint merge 7.4.x to 7.5.x
  • PR-3333 - Ensure encoders are synced when decoding sensitive metadata
  • PR-3332 - Fix NPE when listing versions by id
  • PR-3327 - Add additional tests for draft 2019-09 (#81)
  • PR-3328 - Add dedupe test for same schema w/different version (#82)
  • PR-3322 - Allow SR to ignore confluent:version when matching schemas
  • PR-3265 - Add performanceMetric to get config metadata API
  • PR-3271 - chore: update repo by service bot
  • PR-57 - Changed id from long to int.
  • 14ca9b60 - Fix master branch
  • PR-3224 - Fix Build After Migration of JaasTestUtils to Java