Confluent Platform Component Changelogs

This topic provides changelogs for the individual Confluent Platform components.

Version 7.7.1

setnoindex:True

Released August 2024

Community Features

Common

  • PR-637 - adding cp-jar-build ci gating
  • PR-629 - Bump protobuf version to 3.25.4
  • PR-2 - Remove IntelliJ and build output and add it to .gitignore.
  • ab0d4be5 - Update pom.xml
  • 2add2049 - pin classgraph
  • 1825f6c2 - update azure-identity to 1.12.2
  • 57dce6aa - Remove bouncy property
  • 3753b015 - Remove bcprov-jdk15on

Kafka

  • PR-16951 - Back-port KAFKA-16230 to 3.7 branch (#16951)
  • PR-16996 - local log retention ms/bytes “-2” is not treated correctly (#16996)
  • PR-16858 - Fix the behavior of delegation tokens that expire immediately upon creation in KRaft mode (#16858)
  • PR-16672 - AssignmentsManager gets stuck retrying on deleted topics (#16672)
  • PR-16763 - Update zstd-jni lib (#16763)
  • PR-16678 - Fix MirrorMaker2 worker config does not pass config.provi… (#16678)
  • PR-16616 - Remove print MetaPropertiesEnsemble from kafka-storage tool (#16607) (3.7) (#16616)

ksqlDB

  • PR-63 - Checkstyle fixes
  • PR-62 - Remove unnecessary exclusions
  • PR-61 - Remove unused imports
  • PR-60 - Removed the imlicit topic generation from th estatement executor.
  • PR-59 - Added partition by clause to CSAS statement
  • PR-52 - Inherit from common POM, clean up dependencies
  • PR-50 - json processing
  • PR-49 - Fixed the issue with COUNT(*).
  • PR-47 - Make tabular output for ‘DESCRIBE …’ statements a little prettier
  • PR-10403 - Add a null check in the response object to avoid NPE while accessing the connection status.
  • PR-37 - Remove custom JSON (de)serialization, use Jackson’s ObjectMapper instead
  • PR-10398 - Package kafka streams in api client
  • PR-10397 - Increase time limit for the pipeline
  • PR-10392 - Change classgraph version to 4.8.59
  • PR-9 - Leverage ARG (Avro Random Generator) in DataGen class
  • PR-10380 - Use range version instead of pinned nano-versions
  • 3116084b - Use range version instead of pinned nano-versions
  • 88704d16 - Use range version instead of pinned nano-versions
  • ea2c84c9 - Use range version instead of pinned nano-versions
  • af2b0440 - Use range version instead of pinned nano-versions
  • e65fd80d - Use range version instead of pinned nano-versions
  • ddcda7d2 - Use range version instead of pinned nano-versions(to fix build failure)
  • PR-10369 - Add kafka streams dependency on ksqldb api client

REST Proxy

Schema Registry

  • PR-33 - Moved key serialization to a JSON serializer.
  • PR-30 - APIs changed to refer to subjects. Retrieval by globally unique schema id
  • PR-3235 - Fix Pint Merge Error
  • PR-25 - Issue 5
  • PR-11 - Moves hard-coded configs
  • 51f62d2f - Dedupe schemas during IMPORT mode

Version 7.7.0

Released June 2024

Community Features

Common

  • ac056ff0 - Remove dependency-check-maven plugin
  • bd3ffe2c - update jackson to match ce-kafka.
  • 199fb826 - [skip ci] Copy CODEOWNERS from the default branch
  • e9232f50 - add aws-sdk bom instead of just core
  • e5506701 - unify versions of aws and azure sdks with ce-kafka
  • 664220bd - add correct version of tls_fips
  • 70c2d3e7 - add bcpkix to the pack
  • 1ee85034 - add version definitions of bouncycastle fips dependencies
  • 4f0ba3a2 - Update pom.xml
  • PR-604 - CCMSG-2462: netty-bom version should be picked up from netty.version property
  • 5e9c5ab4 - add new line
  • 5099df8f - Fix codeowners
  • c6e03ed1 - Update bouncycastle version to 1.78
  • 4caab334 - replace EOL plugin with ant-run invocation
  • c2f222bf - update bouncycastle to address CVEs
  • e21ffc4e - revert #595 to remediate downstream build failures
  • e29ec833 - update netty to 4.1.108-final
  • 64ff93dc - Update pom.xml
  • 8d984cba - [CC-26337] Version bump for Jackson Databind package
  • b59f48d2 - update ZooKeeper to 3.8.4
  • ada22e3c - update netty to 4.1.108.Final
  • 4fb11814 - Remove auto-generated CODEOWNERS. It’s inaccurate.
  • 52b0f806 - Remove CODEOWNERS file
  • 7a96a215 - Add service.yml
  • c4b849a5 - update jose4j to address CVE-2023-51775
  • 4c8d3021 - update jetty to 9.4.54
  • PR-581 - fix: no implicit activation of docker-arm profile
  • 8e2bb637 - fix: no implicit activation of docker-arm profile
  • PR-563 - added a new docker-arm profile to build docker containers in arm64
  • PR-574 - Fix CODEOWNERS
  • PR-556 - Upgrade protobuf to 3.24.4
  • ab03eece - added a new docker-arm profile to build docker containers in arm64 laptops
  • 0fe414fb - downgrade fips library to a version that is certified compliant

Kafka

  • PR-1316 - Update refs to confluent-packaging-tools 3.7
  • PR-15473 - KAFKA-16252: Fix the documentation and adjust the format (#15473)
  • PR-16379 - KAFKA-16988: add 1 more node for test_exactly_once_source system test (#16379)
  • PR-16366 - KAFKA-16969: Log error if config conficts with MV (#16366)
  • PR-16229 - KAFKA-16570 FenceProducers API returns “unexpected error” when succes… (#16229)
  • PR-16053 - KAFKA-9228: Restart tasks on runtime-only connector config changes (#16053)
  • PR-16232 - KAFKA-16886: Detect replica demotion in AssignmentsManager (#16232)
  • PR-15834 - KAFKA-16606 Gate JBOD configuration on 3.7-IV2 (#15834)
  • PR-15689 - KAFKA-12317: Update FK-left-join documentation (#15689)
  • PR-16165 - KAFKA-16814 KRaft broker cannot startup when partition.metadata is missing (#16165)
  • PR-16118 - KAFKA-16583: Handle PartitionChangeRecord without directory IDs (#16118)
  • 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-15165 - KAFKA-16105: Reset read offsets when seeking to beginning in TBRLMM (#15165)
  • PR-16175 - KAFKA-16881: InitialState type leaks into the Connect REST API OpenAPI spec (#16175)
  • PR-16042 - KAFKA-16807 DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions (#16042)
  • 327b696b - KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2
  • PR-16005 - KAFKA-16790: Update RemoteLogManager configuration in broker server (#16005)
  • PR-16072 - KAFKA-16371; fix lingering pending commit when handling OFFSET_METADATA_TOO_LARGE (#16072)
  • PR-15910 - KAFKA-15905 Restarts of MirrorCheckpointTask should not permanently i… (#15910)
  • PR-16038 - KAFKA-16825: Update netty/jetty/jackson/zstd dependencies (#16038)
  • PR-15971 - KAFKA-16992: InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when upgrading from kafka (#15971)
  • PR-15953 - KAFKA-16539 Fix IncrementalAlterConfigs during ZK migration (#15744) (#15953)
  • PR-1235 - APPSEC-3974: Updated netty version to 4.1.108.Final
  • PR-13965 - KAFKA-15170: Fix rack-aware assignment in AbstractStickyAssignor (#13965)
  • PR-15416 - KAFKA-16277: AbstractStickyAssignor - Sort owned TopicPartitions by partition when reassigning (#15416)
  • PR-15149 - KAFKA-16093: Fix spurious REST-related warnings on Connect startup (#15149)
  • PR-15817 - KAFKA-16511: Fix the leaking tiered segments during segment deletion (#15817)
  • PR-15732 - KAFKA-16563: retry pollEvent in KRaftMigrationDriver for retriable errors (#15732)
  • PR-15755 - cherrypick KAFKA-16386: Convert NETWORK_EXCEPTIONs from KIP-890 transaction verification (#15755)
  • PR-15792 - KAFKA-16217 Stop the abort transaction try loop when closing producers (#15541) (#15792)
  • PR-15361 - KAFKA-15625: Do not flush global state store at each commit (#15361)
  • PR-1172 - update tags and added seamphore tags as part of semaphore migration 3.7
  • PR-15777 - KAFKA-16082 Avoid resuming future replica if current replica is in the same directory (#15777)
  • PR-15701 - KAFKA-16466: Log exception message for non-fault errors in QuorumController (#15701)
  • PR-15776 - KAFKA-16559 allow defining number of disks per broker in TestKitNodes (#15776)
  • PR-15747 - KAFKA-16073: Increment the local-log-start-offset before deleting segments in memory table (#15631) (#15747)
  • PR-15022 - KAFKA-16003: Always create the /config/topics ZNode even for topics without configs (#15022)
  • PR-15397 - KAFKA-16286; Notify listener of latest leader and epoch (#15397)
  • PR-15695 - KAFKA-16509: CurrentControllerId metric is unreliable in ZK mode (#15695)
  • PR-15648 - KAFKA-16463 Delete metadata log on ZK broker startup (#15648)
  • PR-15658 - KAFKA-16473: Use correct cluster ID when formatting log dir. (#15658)
  • PR-14995 - KAFKA-14822: Allow restricting File and Directory ConfigProviders to specific paths (#14995)
  • PR-15557 - KAFKA-16297: Race condition while promoting future replica (#15557)
  • PR-15409 - KAFKA-16293: Test log directory failure in Kraft (#15409)
  • PR-15335 - KAFKA-16234: Log directory failure re-creates partitions in another logdir automatically (#15335)
  • PR-15663 - KAFKA-16472 Fix integration tests in Java with parameter name (#15663)
  • PR-15434 - KAFKA-16305: Avoid optimisation in handshakeUnwrap (#15434)
  • PR-15655 - KAFKA-16471 invoke SSLEngine::closeInbound on SslTransportLayer close (#15655)
  • PR-15532 - KAFKA-16359: Corrected manifest file for kafka-clients (#15532)
  • PR-15521 - KAFKA-16365: AssignmentsManager callback handling issues (#15521)
  • fc646f92 - Revert “KAFKA-16342 fix getOffsetByMaxTimestamp for compressed records (#15474)”
  • bd5989dd - Revert “KAFKA-16341 fix the LogValidator for non-compressed type (#15476)”
  • PR-15608 - KAFKA-16428: Fix bug where config change notification znode may not get created during migration (#15608)
  • PR-15584 - KAFKA-16411: Correctly migrate default client quota entities (#15584)
  • PR-15562 - KAFKA-16392: Stop emitting warning log message when parsing source connector offsets with null partitions (#15562)
  • PR-15591 - KAFKA-16410 kafka-leader-election / LeaderElectionCommand doesn’t set exit code on error (#15591)
  • PR-15583 - KAFKA-16408 kafka-get-offsets / GetOffsetShell doesn’t handle –version or –help (#15583)
  • PR-1013 - KSECURITY-2090 master update bcprov-jdk15on for the CVE in this jira
  • PR-1064 - KSECURITY-2349 Fix CVE-2024-22201 for jetty
  • PR-15481 - KAFKA-16222: desanitize entity name when migrate client quotas (#15481)
  • PR-15476 - KAFKA-16341 fix the LogValidator for non-compressed type (#15476)
  • PR-15530 - KAFKA-16369: Broker may not shut down when SocketServer fails to bind as Address already in use (#15530)
  • PR-15464 - KAFKA-16322 upgrade jline from 3.22.0 to 3.25.1 (#15464)
  • PR-15474 - KAFKA-16342 fix getOffsetByMaxTimestamp for compressed records (#15474)
  • PR-15493 - KAFKA-16226; Reduce synchronization between producer threads (#15323) (#15493)
  • 4cd36f93 - TRIVIAL: fix typo
  • PR-15088 - KAFKA-16025: Fix orphaned locks when rebalancing and store cleanup race on unassigned task directories (#15088)
  • PR-15479 - KAFKA-16319: Divide DeleteTopics requests by leader node (#15479)
  • PR-15480 - KAFKA-16347: Upgrade zookeeper 3.8.3 -> 3.8.4 (#15480)
  • PR-15444 - KAFKA-16209 : fetchSnapshot might return null if topic is created before v2.8 (#15444)
  • PR-15398 - KAFKA-16278: Missing license for scala related dependencies (#15398)
  • PR-14631 - KAFKA-15670: add “inter.broker.listener.name” config in KRaft controller config (#14631)
  • PR-15347 - [MINOR] Fix docker image build by introducing bash (#15347)
  • PR-15051 - Update Streams API broker compat table for AK 3.7 (#15051)
  • PR-15263 - KAFKA-16157: fix topic recreation handling with offline disks (#15263)
  • PR-15293 - KAFKA-16180: Fix UMR and LAIR handling during ZK migration (#15293)
  • PR-15262 - KAFKA-16195: ignore metadata.log.dir failure in ZK mode (#15262)
  • a1addb56 - Revert “KAFKA-16101: Additional fixes on KRaft migration documentation (#15287)”
  • 945f4b91 - KAFKA-16216: Reduce batch size for initial metadata load during ZK migration
  • PR-15291 - Update jetty to 9.4.53.v20231009 for CVE-2023-36478 (#15291)
  • PR-15287 - KAFKA-16101: Additional fixes on KRaft migration documentation (#15287)
  • cf6defb8 - KAFKA-16162: resend broker registration on metadata update to IBP 3.7-IV2
  • b5a19053 - Update jetty to 9.4.53.v20231009 for CVE-2023-36478
  • PR-15284 - KAFKA-16210: Update jose4j to 0.9.4 (#15284)
  • 5a861075 - KAFKA-14616: Fix stray replica of recreated topics in KRaft mode
  • PR-15193 - KAFKA-16101: Fix KRaft migration documentation (#15193)
  • b7098722 - KAFKA-16171: Fix ZK migration controller race #15238
  • PR-15133 - KAFKA-16085: Add metric value consolidated for topics on a broker for tiered storage. (#15133)
  • PR-15151 - KAFKA-15594: Add version 3.6 to Kafka Streams system tests (#15151)
  • PR-15186 - KAFKA-16029: Fix “Unable to find FetchSessionHandler for node X” bug (#15186)
  • PR-15235 - KAFKA-16144: skip checkQuorum for only 1 voter case (#15235)
  • PR-15236 - Note that Java 11 support for broker and tools is deprecated for removal in 4.0 (#15236)
  • PR-15217 - KAFKA-16141: Fix StreamsStandbyTask system test (#15217)
  • PR-15228 - KAFKA-16159: MINOR - Correcting logs to debug telemetry reporter (#15228)
  • 3c923302 - KAFKA-16078: Be more consistent about getting the latest MetadataVersion
  • PR-15197 - KAFKA-16131: Only update directoryIds if the metadata version supports DirectoryAssignment (#15197)
  • PR-15207 - KAFKA-16139: Fix StreamsUpgradeTest (#15207)
  • PR-15199 - KAFKA-16139: Fix StreamsUpgradeTest (#15199)
  • b743f6fd - KAFKA-16126: Kcontroller dynamic configurations may fail to apply at startup
  • b4036833 - KAFKA-16126: Kcontroller dynamic configurations may fail to apply at startup
  • 7486223d - KAFKA-16120: Fix partition reassignment during ZK migration
  • PR-15182 - KAFKA-16118; Coordinator unloading fails when replica is deleted (#15182)
  • PR-15194 - KAFKA-16133 - Reconciliation auto-commit fix (#15194)
  • 4280df48 - KAFKA-16120: Fix partition reassignment during ZK migration
  • PR-15177 - KAFKA-16017: Checkpoint restored offsets instead of written offsets (#15177)
  • PR-15077 - KAFKA-16074: close leaking threads in replica manager tests (#15077)
  • PR-15153 - KAFKA-16094: BrokerRegistrationRequest.logDirs field must be ignorable (#15153)
  • PR-15145 - KAFKA-16089: Revert “KAFKA-14412: Better Rocks column family management” (#15145)
  • PR-15146 - KAFKA-16097: Disable state updater in 3.7 (#15146)
  • PR-15048 - KAFKA-16016: Add docker wrapper in core and remove docker utility script (#15048)
  • PR-15132 - KAFKA-16059: close more kafkaApis instances (#15132)
  • PR-15117 - KAFKA-16077: Streams with state updater fails to close task upon fencing (#15117)
  • PR-15135 - KAFKA-16086: Fix memory leak in RocksDBStore (#15135)
  • PR-15122 - KAFKA-16079: fix threads leak threads in LocalLeaderEndPointTest and other tests (#15122)
  • PR-14980 - KAFKA-15817: Avoid reconnecting to the same IP address (#14813) (#14980)
  • PR-15073 - KAFKA-16046: also fix stores for outer join (#15073)
  • PR-15096 - KAFKA-9545: Fix IllegalStateException in updateLags (#15096)
  • PR-15093 - KAFKA-16059: Fix thread leak KafkaAPIsTest (#15093)
  • PR-15094 - KAFKA-16052: Save heap in AbstractCoordinatorConcurrencyTest by creating real ReplicaManager (#15094)
  • PR-15089 - KAFKA-16062: Upgrade mockito to 5.8.0 (#15089)
  • PR-15090 - KAFKA-16065: close DelayedFuturePurgatory in DelayedOperationTest (#15090)
  • PR-15030 - KAFKA-16015: Fix custom timeouts overwritten by defaults in LeaderElectionCommand (#15030)
  • PR-15084 - KAFKA-16058: close controllerApi instance to avoid thread leaks (#15084)
  • PR-15079 - KAFKA-16053: Fix memory leaks due to KDC server in tests (#15079)
  • PR-15023 - KAFKA-16012: Ensure new leader information merged correctly with the current metadata (#15023)
  • PR-15061 - KAFKA-16046: fix stream-stream-join store types (#15061)
  • PR-15035 - KAFKA-16026: Send Poll event to the background thread (#15035)
  • PR-15056 - KAFKA-16035: add tests for remoteLogSizeComputationTime/remoteFetchExpiresPerSec metrics (#15056)
  • PR-15050 - KAFKA-16014: Implement RemoteLogSizeBytes (#15050)
  • PR-15059 - KAFKA-16040; Rename Generic to Classic (#15059)
  • PR-14985 - KAFKA-14505; [3/N] Wire WriteTxnMarkers API (#14985)
  • PR-14557 - KAFKA-15456: Commit/Fetch error handling improvements and V9 support (#14557)
  • PR-15043 - KAFKA-16030: new group coordinator should check if partition goes offline during load (#15043)
  • PR-15053 - KAFKA-16036; Add group.coordinator.rebalance.protocols and publish all new configs (#15053)
  • PR-15044 - KAFKA-16017: Checkpoint restored offsets instead of written offsets (#15044)
  • PR-15015 - KAFKA-16013: Throw an exception in DelayedRemoteFetch for follower fetch replicas. (#15015)
  • PR-15005 - KAFKA-16002: Implement RemoteCopyLagSegments, RemoteDeleteLagBytes and RemoteDeleteLagSegments (#15005)
  • PR-14937 - KAFKA-15696: Refactor closing consumer (#14937)
  • PR-14930 - KAFKA-15913: Migrate async consumer tests to mocks (#14930)
  • PR-15032 - KAFKA-15874: Add metric and request log attribute for deprecated request api versions (KIP-896) (#15032)
  • PR-15026 - KAFKA-16014: Add RemoteLogMetadataCount metric (#15026)
  • PR-14848 - KAFKA-15870: Move new group coordinator metrics from Yammer to Metrics (#14848)
  • PR-14977 - KAFKA-15366: Modify LogDirFailureTest for KRaft (#14977)
  • PR-15007 - KAFKA-16007 Merge batch records during ZK migration (#15007)
  • PR-15039 - KAFKA-15448: Update upgrade guide for KIP-988 (#15039)
  • PR-13662 - KAFKA-15208: Upgrade Jackson dependencies to version 2.16.0 (#13662)
  • PR-14375 - KAFKA-15158: Add metrics for RemoteDelete and BuildRemoteLogAuxState (#14375)
  • PR-15042 - KAFKA-15364: Replay BrokerRegistrationChangeRecord.logDirs (#15042)
  • PR-15021 - KAFKA-16014: Add RemoteLogSizeComputationTime metric (#15021)
  • PR-15014 - KAFKA-16013: Add metric for expiration rate of delayed remote fetch (#15014)
  • PR-14832 - KAFKA-15883: Implement RemoteCopyLagBytes (#14832)
  • PR-14925 - KAFKA-15971: Re-enable consumer integration tests for new consumer (#14925)
  • PR-14962 - KAFKA-15775: New consumer listTopics and partitionsFor (#14962)
  • PR-14640 - KAFKA-15276: Implement event plumbing for ConsumerRebalanceListener callbacks (#14640)
  • PR-14996 - KAFKA-15471 [MINOR]: Fix backward-compatibility bug (#14996)
  • PR-14984 - KAFKA-15922: Bump MetadataVersion to support JBOD with KRaft (#14984)
  • PR-14774 - KAFKA-15784: Ensure atomicity of in memory update and write when transactionally committing offsets (#14774)
  • PR-14981 - KAFKA-15237: Implement write operation timeout (#14981)
  • PR-14988 - KAFKA-15981: update Group size only when groups size changes (#14988)
  • PR-14293 - KAFKA-15372: Reconfigure dedicated MM2 connectors after leadership change (#14293)
  • PR-14649 - KAFKA-15695: Update the local log start offset of a log after rebuilding the auxiliary state (#14649)
  • PR-14990 - KAFKA-15881: Update Release Process for Docker images documentation (#14990)
  • PR-14873 - KAFKA-15818: ensure leave group on max poll interval (#14873)
  • PR-14400 - KAFKA-15471: Allow independently stop KRaft controllers or brokers (#14400)
  • PR-14942 - KAFKA-15358: Added QueuedReplicaToDirAssignments metric (#14942)
  • PR-14938 - KAFKA-15879: Add documentation and examples for docker image (#14938)
  • PR-14967 - KAFKA-15906: Emit latest MM2 offset syncs every offset.flush.interval.ms (#14967)
  • PR-14562 - KAFKA-15563: Provide informative error messages when Connect REST requests time out (#14562)
  • PR-14857 - KAFKA-15574; [2/N]: Client state machine updates (#14857)
  • PR-14982 - KAFKA-15363: Run completion handlers for duped AssignmentEvent (#14982)
  • PR-14881 - KAFKA-15365: Broker-side replica management changes (#14881)
  • PR-14948 - KAFKA-15662: Add support for clientInstanceIds in Kafka Stream (#14948)
  • PR-14945 - KAFKA-15978: Update member information on HB response (#14945)
  • PR-14899 - KAFKA-15956: MetadataShell must take the log directory lock when reading (#14899)
  • PR-14970 - KAFKA-15714: KRaft support in DynamicNumNetworkThreadsTest (#14970)
  • PR-14902 - KAFKA-15364: Handle log directory failure in the Controller (#14902)
  • PR-14304 - KAFKA-13328, KAFKA-13329 (1): Add preflight validations for key, value, and header converter classes (#14304)
  • PR-14976 - KAFKA-15361: Migrating brokers must register with directory list (#14976)
  • PR-14935 - KAFKA-15662: Add support for clientInstanceIds in Kafka Stream (#14935)
  • PR-14911 - KAFKA-14516: [3/3] Integration Test - Static Member Removed After Session Timeout (#14911)
  • PR-14964 - KAFKA-15986: Fix integration test failures (#14964)
  • PR-14961 - Revert “MINOR: Add junit properties to display parameterized test names (#14687)” (#14961)
  • PR-14790 - KAFKA-15363: Broker log directory failure changes (#14790)
  • PR-14907 - KAFKA-15629: Support ResultOrder to TimestampedRangeQuery. (#14907)
  • PR-14939 - KAFKA-15977: Fix leak in DelegationTokenEndToEndAuthorizationWithOwnerTest (#14939)
  • c515bf51 - KAFKA-15426: Process and persist directory assignments
  • PR-14922 - KAFKA-15662: Add support for clientInstanceIds in Kafka Stream (#14922)
  • PR-14906 - KAFKA-15527: Support ResultOrder to reverseRange and reverseAll query over kv-store in IQv2 (#14906)
  • PR-12728 - KAFKA-14132; Replace EasyMock with Mockito in StandaloneHerderTest (#12728)
  • PR-14845 - KAFKA-14505; [2/N] Implement TxnOffsetCommit API (#14845)
  • PR-14940 - KAFKA-15903: Add Github Actions Workflow for building and pushing RC Docker Image (#14940)
  • PR-14941 - KAFKA-15880: Add Github Actions Workflow for Promoting an RC docker image (#14941)
  • PR-14749 - KAFKA-15980: Add the CurrentControllerId metric (#14749)
  • PR-14947 - KAFKA-15347: fix unit test (#14947)
  • PR-14898 - KAKFA-15629: Update upgrade-guide.html for TimestampedKeyQuery and TimestampedRangeQuery (#14898)
  • PR-14838 - KAFKA-15361: Process and persist dir info with broker registration (#14838)
  • PR-14933 - KAFKA-15684: Support to describe all client metrics resources (KIP-714) (#14933)
  • PR-14761 - KAFKA-15816: Fix leaked sockets in mirror tests (#14761)
  • PR-14926 - KAFKA-15871: kafka-client-metrics.sh (#14926)
  • PR-14912 - KAFKA-15932: Wait for responses in consumer operations (#14912)
  • PR-14849 - KAFKA-15910: New group coordinator needs to generate snapshots while loading (#14849)
  • PR-14921 - KAFKA-15022: tests for HA assignor and StickyTaskAssignor (#14921)
  • PR-14626 - KAFKA-15347: add support for ‘single key multi timestamp’ IQs with versioned state stores (KIP-968) (#14626)
  • PR-14924 - KAFKA-15972: Add support to exclude labels for telemetry metrics (KIP-714) (#14924)
  • PR-14916 - KAFKA-15970: Copy over KIP-951 tests in FetcherTest.java to FetchRequestManagerTest.java (#14916)
  • PR-14878 - KAFKA-15280: Implement client support for KIP-848 server-side assignors (#14878)
  • PR-14552 - KAFKA-15445: Add JVM Docker image (#14552)
  • PR-14735 - KAFKA-15448: Streams Standby Update Listener (KIP-988) (#14735)
  • PR-14879 - KAFKA-15281: Implement the groupMetadata Consumer API (#14879)
  • PR-14714 - KAFKA-15022: introduce interface to control graph constructor (#14714)
  • PR-14928 - [MINOR-PR] Enable telemetry APIs and logs suppression (KIP-714) (#14928)
  • PR-14107 - Kafka-14748: Relax non-null FK left-join requirement (#14107)
  • PR-14750 - KAFKA-15816: Fix leaked sockets in clients tests (#14750)
  • PR-14908 - KAFKA-15662: Add support for clientInstanceIds in Kafka Stream (#14908)
  • PR-14843 - KAFKA-15901: Client changes for registering telemetry and API calls (KIP-714) (#14843)
  • PR-14811 - KAFKA-15831: KIP-1000 protocol and admin client (#14811)
  • PR-14882 - KAFKA-14516: [2/N] Integration Test - Static Member Gets Assignment Back (#14882)
  • PR-14588 - KAFKA-15645: Move ReplicationQuotasTestRig to tools module (#14588)
  • PR-14852 - KAFKA-14412: Better Rocks column family management (#14852)
  • PR-14870 - KAFKA-14987 [2/2]; customize retry backoff for group/offsets expiration (#14870)
  • PR-14885 - KAFKA-15061; CoordinatorPartitionWriter should reuse buffer (#14885)
  • PR-14767 - KAFKA-15830: Add telemetry API handling (KIP-714) (#14767)
  • PR-14567 - KAFKA-13988: Enable replicating from latest offset with MirrorMaker 2 (#14567)
  • PR-14909 - KAFKA-15663, KAFKA-15794: Telemetry reporter and request handling (KIP-714) (#14909)
  • PR-13932 - KAFKA-14133: Migrate ProcessorStateManagerTest and StreamThreadTest to Mockito (#13932)
  • PR-14544 - KAFKA-14509: [2/N] Implement server side logic for ConsumerGroupDescribe API (#14544)
  • PR-14872 - KAFKA-14438: Throw if async consumer configured with invalid group ID (#14872)
  • PR-14897 - KAFKA-15953: Refactor polling delays (#14897)
  • PR-14835 - KAFKA-15890: Consumer.poll with long timeout unaware of assigned partitions (#14835)
  • PR-14859 - KAFKA-15842: Correct handling of KafkaConsumer.committed for new consumer (#14859)
  • 6b87c852 - KAFKA-15886: Always specify directories for new partition registrations
  • PR-14570 - KAFKA-15629: Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery (#14570)
  • PR-14428 - KAFKA-15489: resign leadership when no fetch or fetch snapshot from majority voters (#14428)
  • PR-14860 - KAFKA-15922: Add a MetadataVersion for JBOD (#14860)
  • PR-14839 - KAFKA-14412: Add ProcessingThread tag interface (#14839)
  • PR-14646 - KAFKA-15689: Logging skipped event when expected migration state is wrong (#14646)
  • PR-14651 - Using INFO level for migration transition state logging (#14651)
  • PR-14769 - KAFKA-15816: Fix leaked sockets in streams tests (#14769)
  • PR-14711 - KAFKA-15022: add config for balance subtopology in rack aware task assignment (#14711)
  • PR-14831 - KAFKA-15865: Remove autocommit completion event (#14831)
  • PR-14242 - KAFKA-15046: Get rid of unnecessary fsyncs inside UnifiedLog.lock to stabilize performance (#14242)
  • PR-14699 - KAFKA-15778 & KAFKA-15779: Implement metrics manager (KIP-714) (#14699)
  • PR-14844 - KAFKA-14505; [1/N] Add support for transactional writes to CoordinatorRuntime (#14844)
  • PR-14865 - Update NOTICE-binary with latest additions (#14865)
  • PR-14842 - KAFKA-15887: Ensure FindCoordinatorRequest is sent before closing (#14842)
  • 14571054 - KAFKA-15904: Only add directory.id to meta.properties when migrating or in kraft mode
  • PR-14620 - KAFKA-15618: Kafka metrics collector and supporting classes (KIP-714) (#14620)
  • PR-14198 - KAFKA-15022: Only relax edge when path exist (#14198)
  • PR-14758 - KAFKA-15544: Enable integration tests for new consumer (#14758)
  • PR-14432 - KAFKA-14516: [1/N] Static Member leave, join, re-join request using ConsumerGroupHeartbeats (#14432)
  • PR-14632 - KAFKA-15681: Add support of client-metrics in kafka-configs.sh (KIP-714) (#14632)
  • PR-14784 - KAFKA-15582 Unset the previous broker epoch if version < 2 (#14784)
  • PR-14696 - KAFKA-15022: Detect negative cycle from one source (#14696)
  • PR-14766 - KAFKA-15047: Roll active segment when it breaches the retention policy (#14766)
  • PR-14751 - KAFKA-15819: KafkaServer.shutdown should free KafkaRaftManager (#14751)
  • PR-14813 - KAFKA-15817: Avoid reconnecting to the same IP address (#14813)
  • PR-14787 - KAFKA-15241: Compute tiered copied offset by keeping the respective epochs in scope (#14787)
  • PR-14756 - KIP-978: Allow dynamic reloading of certificates with different DN / SANs (#14756)
  • PR-14817 - KAFKA-15803: Update leader epoch in commitAsync and committed (#14817)
  • PR-14800 - KAFKA-15856: Add integration tests for JoinGroup API and SyncGroup API (#14800)
  • PR-14781 - KAFKA-15756: [1/2] Migrate existing integration tests to run old protocol in new coordinator (#14781)
  • PR-14825 - KAFKA-15888: DistributedHerder log context should not use the same client ID for each Connect worker by default (#14825)
  • PR-14746 - KAFKA-15555: Ensure wakeups are handled correctly in poll() (#14746)
  • PR-14481 - KAFKA-15484: General Rack Aware Assignor (#14481)
  • PR-14807 - KAFKA-15860: ControllerRegistration must be written out to the metadata image (#14807)
  • PR-988 - KSECURITY-2090: Updated bcpkix to 1.77
  • PR-987 - KSECURITY-2090: Updated bcpkix version to 1.77
  • PR-14582 - KAFKA-15578: Migrating other system tests to use the group coordinator (#14582)
  • PR-14648 - KAFKA-15215: [KIP-954] support custom DSL store providers (#14648)
  • PR-14710 - KAFKA-15327: Ensure the commit manager commit on close (#14710)
  • PR-14737 - KAFKA-15362: Resolve offline replicas in metadata cache (#14737)
  • PR-14810 - KAFKA-15837: Throw error on use of Consumer.poll(long timeout) in AsyncKafkaConsumer (#14810)
  • PR-14656 - KAFKA-15705: Add integration tests for Heartbeat API and GroupLeave API (#14656)
  • PR-14387 - KAFKA-14519; [2/N] New coordinator metrics (#14387)
  • PR-14789 - KAFKA-15836: KafkaConsumer subscribes to multiple topics does not respect max.poll.records (#14789)
  • PR-14690 - KAFKA-15574; [1/N]: Client state machine updates (#14690)
  • PR-14680 - KAFKA-15174: Ensure CommitAsync propagate the exception to the user (#14680)
  • PR-14796 - KAFKA-15854: Move Java classes from kafka.server to the server module (#14796)
  • PR-14779 - KAFKA-15833: Restrict Consumer API to be used from one thread (#14779)
  • PR-14785 - KAFKA-15849: Fix ListGroups API when runtime partition size is zero (#14785)
  • a03a71d7 - KAFKA-15357: Aggregate and propagate assignments
  • PR-14747 - Revert “Revert “KAFKA-15661: KIP-951: Server side changes (#14444)” (#14738)” (#14747)
  • PR-14719 - KAFKA-15799 Handle full metadata updates on ZK brokers (#14719)
  • PR-982 - Update muckrake version mapping for 3.6 (#981)
  • PR-14483 - KAFKA-15481: Fix concurrency bug in RemoteIndexCache (#14483)
  • PR-14482 - KAFKA-15169: Added TestCase in RemoteIndexCache (#14482)
  • PR-981 - Update muckrake version mapping for 3.6
  • PR-14777 - [MINOR] Removing unused variables from StreamThreadTest (#14777)
  • PR-14635 - KAFKA-15755: LeaveGroupResponse v0 - v2 loses its member under certain error conditions (#14635)
  • PR-14759 - KAFKA-15802: Validate remote segment state before fetching index (#14727) (#14759)
  • PR-14596 - KAFKA-15346: add support for ‘single key single timestamp’ IQs with versioned state stores (KIP-960) (#14596)
  • PR-14670 - KAFKA-15277: Design & implement support for internal Consumer delegates (#14670)
  • PR-14704 - KAFKA-15470: Allow creating connectors in a stopped state (#14704)
  • PR-14757 - KAFKA-15824 SubscriptionState’s maybeValidatePositionForCurrentLeader should handle partition which isn’t subscribed yet (#14757)
  • PR-14727 - KAFKA-15802: Validate remote segment state before fetching index (#14727)
  • PR-14545 - KAFKA-15605: Fix topic deletion handling during ZK migration (#14545)
  • PR-14713 - KAFKA-15780: Wait for consistent KRaft metadata when creating or deleting topics (#14695) (#14713)
  • PR-14738 - Revert “KAFKA-15661: KIP-951: Server side changes (#14444)” (#14738)
  • PR-14708 - KAFKA-15774: refactor windowed stores to use StoreFactory (#14708)
  • PR-14718 - KAFKA-15800: Prevent DataExceptions from corrupting KafkaOffsetBackingStore (#14718)
  • PR-14712 - cherrypick KAFKA-15653: Pass requestLocal as argument to callback so we use the correct one for the thread (#14712)
  • PR-14444 - KAFKA-15661: KIP-951: Server side changes (#14444)
  • eaa6b8ab - KAFKA-15360: Include dirs in BrokerRegistration #14392
  • PR-14647 - KAFKA-15693: Immediately reassign lost connectors and tasks when scheduled rebalance delay is disabled (#14647)
  • PR-14506 - KAFKA-15552 Fix Producer ID ZK migration (#14506)
  • PR-14629 - KAFKA-15653: Pass requestLocal as argument to callback so we use the correct one for the thread (#14629)
  • PR-14594 - KAFKA-15583: Enforce HWM advance only if partition is not under-min-ISR (#14594)
  • PR-14674 - KAFKA-15771: fix concurrency bug in ProduceRequest#partitionSizes() (#14674)
  • PR-14659 - KAFKA-15774: introduce internal StoreFactory (#14659)
  • PR-14695 - KAFKA-15780: Wait for consistent KRaft metadata when creating or deleting topics (#14695)
  • PR-14593 - KAFKA-15584: Leader election with ELR (#14593)
  • PR-14630 - KAFKA-15680: Fix sink task partition-count metric when cooperative consumer protocol is used (#14630)
  • PR-14683 - KAFKA-15769: Fix logging with exception trace (#14683)
  • PR-14679 - KAFKA-14133: Move StandbyTaskTest to Mockito (#14679)
  • PR-14416 - KAFKA 14515: Optimized Uniform Rack Aware Assignor (#14416)
  • PR-14621 - KAFKA-15673: Adding client metrics resource types (KIP-714) (#14621)
  • PR-14689 - Add note about KAFKA-15653 (#14689)
  • PR-14290 - KAFKA-15355: Message schema changes (#14290)
  • PR-14642 - KAFKA-15679: Consumer configurations for group protocol (#14642)
  • PR-14667 - KAFKA-15432: RLM Stop partitions should not be invoked for non-tiered storage topics (#14667)
  • PR-14639 - KAFKA-15562: ensure commit request manager handles errors correctly (#14639)
  • PR-14537 - KAFKA-15598 & KAFKA-15461: Add integration tests for DescribeGroups API, DeleteGroups API, OffsetDelete API and ListGroups API (#14537)
  • PR-14618 - KAFKA-15668: Adding Opentelmetry shadowed library (KIP-714) (#14618)
  • PR-14684 - KAFKA-15614: [Minor] Renaming getter and correcting code comments (#14684)
  • PR-14685 - KAFKA-15627: KIP-951’s Leader discovery optimisations on the client (#14685)
  • PR-14607 - KAFKA-14484: [1/N] Move PartitionMetadataFile to storage module (#14607)
  • PR-14623 - KAFKA-14133: Move StreamsMetricsImplTest to Mockito (#14623)
  • PR-13247 - KAFKA-14595 Move ReassignPartitionsCommand to java (#13247)
  • PR-14627 - KAFKA-15661: KIP-951: protocol changes (#14627)
  • PR-14619 - KAFKA-15669: Implement telemetry metric naming strategy (KIP-714) (#14619)
  • PR-14174 - Kafka 12317: Relax non-null key requirement in Kafka Streams (#14174)
  • PR-14589 - KAFKA-15647: Fix the different behavior in error handling between the old and new group coordinator (#14589)
  • PR-14657 - KAFKA-15643: Fix error logged when unload is called on a broker that was never a coordinator. (#14657)
  • PR-14576 - KAFKA-15632: Drop the invalid remote log metadata events (#14576)
  • PR-14603 - KAFKA-15582: Move the clean shutdown file to the storage package (#14603)
  • PR-14617 - KAFKA-15602: revert KAFKA-4852 (#14617)
  • PR-14638 - KAFKA-15628: Refactor ConsumerRebalanceListener invocation for reuse (#14638)
  • 37715862 - KAFKA-15704: Set missing ZkMigrationReady field on ControllerRegistrationRequest
  • PR-14524 - KAFKA-15578: System Tests for running old protocol with new coordinator (#14524)
  • PR-14410 - KAFKA-14133: Replace Easymock with Mockito in StreamsProducerTest, TopologyMetadataTest & GlobalStateStoreProviderTest (#14410)
  • PR-14575 - KAFKA-15614: Define interfaces and classes for client telemetry (#14575)
  • PR-14584 - KAFKA-15644: Fix CVE-2023-4586 in netty:handler (#14584)
  • PR-13321 - KAFKA-15685: Add support for MinGW and MSYS2 (windows OS) (#13321)
  • PR-14636 - KAFKA-15200: Add pre-requisite check in release.py (#14636)
  • PR-14406 - KAFKA-14274 [6, 7]: Introduction of fetch request manager (#14406)
  • PR-14193 - KAFKA-15326: [10/N] Integrate processing thread (#14193)
  • PR-13315 - KAFKA-14767: Fix missing commitId build error after git gc (#13315)
  • PR-14602 - KAFKA-15093: Add 3.5 Streams upgrade system tests (#14602)
  • PR-14611 - KAFKA-15457: Add support for OffsetFetch version 9 in admin client (#14611)
  • PR-14601 - KAFKA-15664: Add 3.4 Streams upgrade system tests (#14601)
  • PR-14563 - KAFKA-15566: Fix test FetchRequestTest.testLastFetchedEpochValidation for KRaft mode (#14563)
  • PR-14539 - KAFKA-15378: fix streams upgrade system test (#14539)
  • PR-14568 - KAFKA-15626: Replace verification guard object with an specific type (#14568)
  • PR-14587 - KAFKA-15607: Fix NPE in MirrorCheckpointTask::syncGroupOffset (#14587)
  • PR-14586 - KAFKA-14133: Move RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest to Mockito (#14586)
  • PR-14538 - KAFKA-15428: Cluster-wide dynamic log adjustments for Connect (#14538)
  • PR-14532 - KAFKA-15534: Inject request completion time when the request failed (#14532)
  • PR-14312 - KAFKA-15581: Introduce ELR (#14312)
  • PR-14465 - KAFKA-15582: Identify clean shutdown broker (#14465)
  • PR-14477 - KAFKA-15527: Add reverseRange and reverseAll query over kv-store in IQv2 (#14477)
  • PR-14554 - KAFKA-15604: Telemetry API request and response schemas and classes (KIP-714) (#14554)
  • PR-14571 - KAFKA-15454: Add support for OffsetCommit version 9 in admin client (#14571)
  • PR-14566 - KAFKA-15616: Client telemetry states and transition (KIP-714) (#14566)
  • PR-14560 - KAFKA-15613: Client API definition and configurations (KIP-714) (#14560)
  • 33b8ee3a - remove unused import
  • PR-14407 - KAFKA-15479: Remote log segments should be considered once for retention breach (#14407)
  • PR-14317 - KAFKA-13973: Fix inflated block cache metrics (#14317)
  • PR-14413 - KAFKA-15554: Client state changes for handling one assignment at a time & minor improvements (#14413)
  • PR-14417 - KAFKA-14519; [1/N] Implement coordinator runtime metrics (#14417)
  • PR-14364 - KAFKA-15278: Implement HeartbeatRequestManager to handle heartbeat requests (#14364)
  • PR-14473 - KAFKA-15521: Refactor build.gradle to align gradle swagger plugin with swagger dependencies (#14473)
  • PR-14381 - KAFKA-14912:Add a dynamic config for remote index cache size (#14381)
  • PR-14291 - KAFKA-15356: Generate and persist directory IDs (#14291)
  • PR-14462 - KAFKA-14504: Implement DescribeGroups API (#14462)
  • PR-14490 - HOTIFX: fix Kafka versions for system tests (#14490)
  • PR-13201 - KAFKA-14596: Move TopicCommand to tools (#13201)
  • PR-967 - KSECURITY-2013: Upgraded Jetty to 9.4.53.v20231009 and Netty to 4.1.100.Final
  • PR-14523 - KAFKA-15569: test and add test cases in IQv2StoreIntegrationTest (#14523)
  • PR-14478 - KAFKA-15532: non active controllers return 0 for ZkWriteBeforelag (#14478)
  • PR-14272 - KAFKA-15390: Do not return fenced broker in FetchResponse.preferredReplica (#14272)
  • PR-14529 - KAFKA-14481: Move LogSegment/LogSegments to storage module (#14529)
  • PR-14505 - KAFKA-14684: Replace EasyMock/PowerMock with Mockito in WorkerSinkTaskThreadedTest (#14505)
  • PR-14511 - KAFKA-15536: Dynamically resize remoteIndexCache (#14511)
  • PR-14361 - KAFKA-15387: Deprecate Connect’s redundant task configurations endpoint (#14361)
  • PR-14527 - KAFKA-15593: Add 3.6 to core upgrade and compatibility tests (#14527)
  • PR-14388 - KAFKA-15465: Don’t throw if MirrorMaker not authorized to create internal topics. (#14388)
  • PR-14535 - KAFKA-15596: Upgrade ZooKeeper to 3.8.3 (#14535)
  • PR-14533 - KAFKA-15492: Upgrade and enable spotbugs when building with Java 21 (#14533)
  • PR-14518 - KAFKA-15570: Add unit tests for MemoryConfigBackingStore (#14518)
  • PR-14467 - KAFKA-14987; Implement Group/Offset expiration in the new coordinator (#14467)
  • PR-14484 - KAFKA-15537: Fix metadata downgrade documentation (#14484)
  • PR-14519 - KAFKA-15571: StateRestoreListener#onRestoreSuspended is never called because DelegatingStateRestoreListener doesn’t implement onRestoreSuspended (#14519)
  • PR-14053 - KAFKA-15221; Fix the race between fetch requests from a rebooted follower. (#14053)
  • PR-14458 - KAFKA-15498: upgrade to snappy 1.1.10.5 (#14458)
  • PR-14522 - KAFKA-15415: On producer-batch retry, skip-backoff on a new leader (#14384) (#14522)
  • PR-14412 - KAFKA-14133: Move MeteredTimestampedKeyValueStoreTest, ReadOnlyWindowStoreFacadeTest and TimestampedWindowStoreBuilderTest to Mockito (#14412)
  • PR-14455 - KAFKA-15507: Make AdminClient throw non-retriable exception for a new call while closing (#14455)
  • PR-14514 - KAFKA-14927: Add validation to be config keys in ConfigCommand tool (#14514)
  • PR-14445 - KAFKA-15502: Update SslEngineValidator to handle large stores (#14445)
  • PR-14384 - KAFKA-15415: On producer-batch retry, skip-backoff on a new leader (#14384)
  • PR-14487 - KAFKA-15547: Fix thread leak in MirrorMakerConfigTest (#14487)
  • PR-14480 - KAFKA-15330: Add missing documentation of metrics introduced as part of KAFKA-15028 (#14480)
  • PR-13927 - KAFKA-10199: Enable state updater by default (#13927)
  • PR-14408 - KAFKA-14506: Implement DeleteGroups API and OffsetDelete API (#14408)
  • PR-14470 - KAFKA-15526: Simplify the LogAppendInfo class (#14470)
  • PR-13204 - KAFKA-14593: Move LeaderElectionCommand to tools (#13204)
  • PR-14456 - KAFKA-14595 ReassignPartitionsIntegrationTest rewritten in java (#14456)
  • PR-14370 - KAFKA-15449: Verify transactional offset commits (KIP-890 part 1) (#14370)
  • PR-14281 - KAFKA-15326: [9/N] Start and stop executors and cornercases (#14281)
  • PR-14441 - KAFKA-15500: Fix condition in SslPrincipalMapper.java (#14441)
  • PR-14459 - KAFKA-15511: Handle CorruptIndexException in RemoteIndexCache (#14459)
  • 60e84562 - Bump version to 3.6.0
  • PR-14457 - KAFKA-15510: Fix follower’s lastFetchedEpoch when fetch response has … (#14457)
  • PR-14442 - KAFKA-10199: Do not unlock state directories of tasks in state updater (#14442)
  • PR-14434 - KAFKA-15498: bump snappy-java version to 1.1.10.4 (#14434)
  • PR-14399 - KAFKA-15466: Add KIP-919 support for some admin APIs (#14399)
  • PR-14226 - KAFKA-15326: [8/N] Move consumer interaction out of processing methods (#14226)
  • PR-14265 - KAFKA-10199: Do not process when in PARTITIONS_REVOKED (#14265)
  • PR-14437 - KAFKA-10199: Fix restoration behavior for paused tasks (#14437)
  • PR-14403 - KAFKA-10199: Add missing catch for lock exception (#14403)
  • PR-14093 - KAFKA-15248 (KIP-959): Add BooleanConverter to Kafka Connect (#14093)
  • PR-14438 - Upgrade Jetty to 9.4.52.v20230823 (#14438)
  • PR-14440 - [KAFKA-15117] In TestSslUtils set SubjectAlternativeNames to null if there are no hostnames (#14440)
  • PR-14433 - KAFKA-15485: Support Java 21 (3/3) (#14433)
  • PR-14427 - KAFKA-15485: Fix “this-escape” compiler warnings introduced by JDK 21 (1/N) (#14427)
  • PR-14355 - KAFKA-14595 ReassignPartitionsUnitTest rewritten in java (#14355)
  • PR-14405 - [MINOR] QuorumController tests use testToImage (#14405)
  • PR-14404 - KAFKA-14133: Move MeteredSessionStoreTest, MeteredWindowStoreTest and ReadOnlyKeyValueStoreFacadeTest to Mockito (#14404)
  • PR-951 - revert gradle enterprise plugin
  • PR-14386 - KAFKA-14960: TopicMetadata request manager (#14386)
  • PR-14376 - KAFKA-15458: Fully resolve endpoint information before registering controllers (#14376)
  • PR-14398 - KAFKA-15473: Hide duplicate plugins in /connector-plugins (#14398)
  • PR-14371 - KAFKA-14855: Harden integration testing logic for asserting that a connector is deleted (#14371)
  • PR-14396 - KAFKA-14133: Move KeyValueIteratorFacadeTest, KeyValueSegmentTest and MeteredKeyValueStoreTest to Mockito (#14396)
  • PR-14344 - KAFKA-15476: Resolves cache misses in checkstyle (#14344)
  • PR-14385 - KAFKA-15306 - Integrating committed offsets for updating fetch positions (#14385)
  • PR-14359 - KAFKA-14274 [2-5/7]: Introduction of more infrastructure for forthcoming fetch request manager (#14359)
  • PR-14393 - Added missing licenses for libraries (#14393)
  • PR-14130 - KAFKA-15273: Log common name of expired client certificates (#14130)
  • PR-14271 - KAFKA-14503: Implement ListGroups (#14271)
  • PR-14382 - KAFKA-15442: add a section in doc for tiered storage (#14382)
  • PR-14347 - KAFKA-15439: Transactions test with tiered storage (#14347)
  • PR-14378 - KAFKA-15459: Convert coordinator retriable errors to a known producer response error (#14378)
  • PR-14346 - KAFKA-15115 - KAFKA-15163; Reset/Validate positions implementation & API integration (#14346)
  • PR-14323 - KAFKA-15275 - Client state machine basic components, states and initial transitions (#14323)
  • PR-14147 - KAFKA-14502; Implement LeaveGroup protocol in new GroupCoordinator (#14147)
  • PR-14367 - KAFKA-15450 Don’t allow ZK migration with JBOD (#14367)
  • PR-14363 - KAFKA-14993: Improve TransactionIndex instance handling while copying to and fetching from RSM (#14363)
  • PR-14349 - KAFKA-15352: Update log-start-offset before initiating deletion of remote segments (#14349)
  • PR-14353 - KAFKA-14499: [7/7] Add integration tests for OffsetCommit API and OffsetFetch API (#14353)
  • PR-14167 - KAFKA-15315: Use getOrDefault rather than get in TransactionState (#14167)
  • PR-14180 - KAFKA-15326: [7/N] Processing thread non-busy waiting (#14180)
  • PR-13562 - KAFKA-14581: Moving GetOffsetShell to tools (#13562)
  • PR-14351 - KAFKA-15441 Allow broker heartbeats to complete in metadata transaction (#14351)
  • PR-14342 - KAFKA-15435 Fix counts in MigrationManifest (#14342)
  • PR-14221 - KAFKA-15338: The metric group documentation for metrics added in KAFKA-13945 is incorrect (#14221)
  • PR-14330 - KAFKA-15410: Delete records with tiered storage integration test (4/4) (#14330)
  • PR-14354 - KAFKA-14273; Close file before atomic move (#14354)
  • PR-14305 - KAFKA-14274 #1: basic refactoring (#14305)
  • PR-14306 - KAFKA-15369: Implement KIP-919: Allow AC to Talk Directly with Controllers (#14306)
  • PR-14314 - KAFKA-15425: Fail fast in Admin::listOffsets when topic (but not partition) metadata is not found (#14314)
  • PR-14341 - KAFKA-15307: Removes non-existent configs (#14341)
  • PR-14217 - KAFKA-14595: ReassignPartitionsCommandArgsTest rewritten in java (#14217)
  • PR-14279 - KAFKA-15179: Add integration tests for the file sink and source connectors (#14279)
  • PR-14124 - KAFKA-14509; [1/2] Define ConsumerGroupDescribe API request and response schemas and classes. (#14124)
  • PR-14340 - KAFKA-15351: Update log-start-offset after leader election for topics enabled with remote storage (#14340)
  • PR-14321 - KAFKA-14499: [6/N] Add MemberId and MemberEpoch to OffsetFetchRequest (#14321)
  • PR-14339 - KAFKA-15422: Update documenttion for delegation tokens when working with Kafka with KRaft (#14339)
  • PR-14329 - KAFKA-15410: Delete topic integration test with LocalTieredStorage and TBRLMM (3/4) (#14329)
  • PR-14111 - KAFKA-9800: Exponential backoff for Kafka clients - KIP-580 (#14111)
  • PR-14331 - KAFKA-15293 Added documentation for tiered storage metrics (#14331)
  • PR-14328 - KAFKA-15410: Reassign replica expand, move and shrink integration tests (2/4) (#14328)
  • PR-14307 - KAFKA-15410: Expand partitions, segment deletion by retention and enable remote log on topic integration tests (1/4) (#14307)
  • PR-14324 - KAFKA-15424: Make the transaction verification a dynamic configuration (#14324)
  • PR-14152 - KAFKA-7438: Migrate WindowStoreBuilderTest from EasyMock to Mockito (#14152)
  • PR-14223 - KAFKA-14133: Move AbstractStreamTest and RocksDBMetricsRecordingTriggerTest to Mockito (#14223)
  • PR-14318 - KAFKA-15422: Update documenttion for delegation tokens when working with Kafka with KRaft (#14318)
  • PR-14113 - KAFKA-15260: RLM Task should handle uninitialized RLMM for the associated topic-parititon (#14113)
  • PR-14320 - KAFKA-15421: fix network thread leak in testThreadPoolResize (#14320)
  • PR-14326 - KAFKA-15429: reset transactionInFlight on StreamsProducer close (#14326)
  • PR-14325 - KAFKA-15429: catch+log errors from unsubscribe in streamthread shutdown (#14325)
  • PR-14308 - KAFKA-14965 - OffsetsRequestsManager implementation & API integration (#14308)
  • PR-14319 - KAFKA-15427: Fix resource leak in integration tests for tiered storage (#14319)
  • PR-14122 - KAFKA-14500; [7/7] Refactor GroupMetadataManagerTest (#14122)
  • PR-14310 - KAFKA-14499: [5/N] Refactor GroupCoordinator.fetchOffsets and GroupCoordinator.fetchAllOffsets (#14310)
  • PR-14301 - KAFKA-15351: Ensure log-start-offset not updated to local-log-start-offset when remote storage enabled (#14301)
  • PR-14171 - Kafka Streams Threading: Timeout behavior (#14171)
  • PR-946 - Revert “KSECURITY-1789: upgrading requests to v2.31.0”
  • daea0fdf - KAFKA-15375: fix broken clean shutdown detection logic in LogManager
  • 703e1d9f - KAFKA-15375: fix broken clean shutdown detection logic in LogManager
  • PR-14222 - KAFKA-14133: Move RocksDBRangeIteratorTest, TimestampedKeyValueStoreBuilderTest and TimestampedSegmentTest to Mockito (#14222)
  • PR-14302 - KAFKA-15412: Reading an unknown version of quorum-state-file should trigger an error (#14302)
  • PR-14161 - KAFKA-15267: Do not allow Tiered Storage to be disabled while topics have remote.storage.enable property (#14161)
  • PR-14303 - KAFKA-13327: Gracefully report connector validation errors instead of returning 500 responses (#14303)
  • PR-14277 - KAFKA-15392: Prevent shadowing RestServer shutdown exceptions (#14277)
  • PR-14118 - KAFKA-14875: Implement wakeup (#14118)
  • PR-14264 - KAFKA-15403: Refactor @Test(expected) annotation with assertThrows (#14264)
  • PR-14294 - KRaft support for DescribeClusterRequestTest and DeleteConsumerGroupsTest (#14294)
  • PR-14120 - KAFKA-14499: [4/N] Implement OffsetFetch API (#14120)
  • PR-14285 - KAFKA-15399: Enable OffloadAndConsumeFromLeader test (#14285)
  • PR-14210 - KAFKA-14133: Move RecordCollectorTest, StateRestoreCallbackAdapterTest and StoreToProcessorContextAdapterTest to Mockito (#14210)
  • PR-14236 - KAFKA-15353: make sure AlterPartitionRequest.build() is idempotent (#14236)
  • PR-14288 - KAFKA-15256: Adding reviewer as part of release announcement email template (#14288)
  • PR-14266 - KAFKA-15294: Publish remote storage configs (#14266)
  • PR-14127 - KAFKA-15181: Wait for RemoteLogMetadataCache to initialize after assigning partitions (#14127)
  • PR-14282 - KAFKA-15389: Don’t publish until we have replayed at least one record (#14282)
  • PR-13561 - KAFKA-14888: Added remote log segments retention mechanism based on time and size. (#13561)
  • PR-14244 - KAFKA-15377: Don’t expose externalized secret values in tasks-config API endpoint (#14244)
  • PR-14278 - KAFKA-15393: Improve shutdown behavior in MM2 integration tests (#14278)
  • PR-14026 - Fix incorrect format specifiers when formatting string (#14026)
  • PR-14238 - Handle topic-level dynamic remote storage enable configuration (#14238)
  • PR-14283 - Use readLock when removing an item from the RemoteIndexCache (#14283)
  • PR-14135 - KIP-937-Improve message timestamp validation (#14135)
  • PR-14280 - Handle concurrent dir rename which makes log-dir to be offline unexpectedly (#14280)
  • PR-14218 - [2/N]: Refactoring for client code to reduce boilerplate (#14218)
  • PR-14208 - Metadata transactions in MetadataLoader (#14208)
  • PR-14204 - Move mocks from KStreamTransformValuesTest, KTableImplTest and KTableTransformValuesTest to Mockito (#14204)
  • PR-14269 - fix grace period partition issue (#14269)
  • PR-14197 - Execute action queue after callback request (#14197)
  • PR-1393 - 3.7 fixed downstream trigger
  • PR-1367 - 3.7 removed mk-include and make init-ci from semaphore
  • e2494e6f - Bump version to 3.7.1

ksqlDB

  • 4781375c - Update ref to confluent-packaging-tools
  • PR-10353 - KSE-1795 | Add support for AnyOf Json type while encoding Ksql schemas.
  • 47e67702 - remove jackson pin to update jackon to version specified in common (2.16.0)
  • e12817d4 - [skip ci] Copy CODEOWNERS from the default branch
  • PR-10355 - MINOR: Update snapshot URLs.
  • PR-10348 - Merge Conflict Resolution (from 7.5.x to 7.6.x)
  • PR-10346 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
  • f8184c49 - KSQL-12164: Disable ITs only for failing modules
  • 7902e36e - KSQL-12164: Disable ITs only for single module
  • aa0c5327 - KSQL-12164: Disable ITs only for single module
  • PR-10340 - KSE-1832 | CVE fix for vertx dependency.
  • PR-10338 - KSE-1832 | CVE fix for vertx dependency.
  • f68591f6 - KSQL-12164: Remove disable ITs flag
  • b0225629 - KSQL-12154: Update plugin version
  • PR-10333 - KSE-1829 | Fix CVE for janino dependency.
  • 72cd094c - KSQL-12154: Update plugin version
  • PR-10330 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
  • PR-10329 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
  • PR-10328 - KSE-1829 | Fix CVE for janino dependency.
  • PR-10321 - [KSQL-12110] | Check if directory exists before cleanup 7.2.x
  • PR-10325 - Merge Conflict Resolution (from 7.5.x to 7.6.x)
  • PR-10323 - [KSQL-12110] | Check if directory exists before cleanup 7.4.x
  • PR-10322 - [KSQL-12110] | Check if directory exists before cleanup 7.3.x
  • 5501cc1d - KSQL-11272: Delete Unused File
  • PR-10307 - [KSQL-12107] | Migrate 7.7.x to ranges
  • PR-10311 - [KSQL-12107] | Migrate 7.3.x to ranges
  • PR-10312 - [KSQL-12107] | Migrate 7.2.x to ranges
  • PR-10308 - [KSQL-12107] | Migrate to 7.6.x to ranges
  • PR-10309 - [KSQL-12107] | Migrate 7.5.x to ranges
  • PR-10310 - [KSQL-12107] | Migrate 7.4.x to ranges
  • PR-10313 - [KSQL-12107] | Migrate 7.1.x to ranges
  • PR-10314 - [KSQL-12107] | Migrate 7.0.x to ranges
  • PR-10315 - [KSQL-12107] | Migrate 6.2.x to ranges
  • PR-10319 - Merge Conflict Resolution (from 7.6.x to 7.7.x)
  • PR-10318 - Merge Conflict Resolution (from 7.3.x to 7.4.x)
  • PR-10317 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
  • PR-10316 - Merge Conflict Resolution (from 7.1.x to 7.2.x)
  • PR-10304 - [KSE-1831] | Update netty version to stable one
  • afc0579f - KSQL-11272: usse correct ksqldb-parent version
  • 4e8ee5b0 - KSQL-11272: Add EOL’d library code to the ksqlDB codebase
  • PR-10297 - [KSQL-12104] | Fix 7.5.x build
  • PR-10303 - [KSE-1831] | Update netty version to stable one
  • c36d53b4 - [KSQL-12104] | Fix 7.6.x build
  • PR-10294 - [KSQL-12103] | Update common version
  • d2e2ed65 - KSQL-12064: Add informational comment
  • c3b70015 - KSQL-12064: Add UTs
  • 732cfbc0 - KSQL-12064: Add num value based Query status metrics
  • 233bebe0 - KSQL-12064: Add num value based CommandRunnerMetrics
  • PR-10278 - [KSQL-12027] | Update common version in pom (7.7.x)
  • 173a4f8e - KSE-1824 | Address review comments.
  • 85b238bf - KSE-1824 | Add a no-arg constructor for ProtobufNoSRConverter.
  • bbf596c8 - [KSE-1820] | Update common in pom to fix PR pipeline
  • 56444690 - [KSE-1820] | Fix formatting
  • 340768db - [KSE-1820] | Extract to constants
  • e5268de8 - [KSE-1820] | Fixes ksql build failures
  • PR-10250 - Merge Conflict Resolution (from 7.6.x to master)
  • PR-10243 - KSE-1816: Update Commons-Compress and commons-io
  • PR-10238 - KSE-1817: Update apache.io.version
  • PR-10237 - KSE-1816: Update commons-compress
  • PR-10234 - MINOR: Pinned the common nanoversion to 7.6.1-3
  • PR-10223 - KSQL-11784: Change groupID to a more secure name
  • 2f84873b - KSQL-11784: Change groupID to a more secure name
  • 5612f336 - KSE-1786 | Increase execution time limit to 6 hours.
  • 30544a65 - KSE-1786 | Cherry pick the replacement of easymock to mockito from newer branches.
  • f969d5c0 - KSE-1786 | Enable pinned nanoversions.
  • b49bbcbb - KSE-1786 | Specify type parameter for CommandStatus.
  • c7288dd0 - KSE-1786 | Remove maven cache restore.
  • cea27ec9 - KSE-1786 | set java version to 8
  • cd59a75a - KSE-1786 | Increase the execution time limit.
  • 26db19fd - KSE-1786 | Fixed the extra args in service.yml file.
  • 37e06168 - KSE-1786 | Fix the parent version in commons.
  • 5467ea20 - KSE-1786 | set java version to 8
  • 0a1cf171 - KSE-1786 | Increase the execution time limit.
  • db81cd09 - KSE-1786 | Fixed the extra args in service.yml file.
  • PR-10167 - fix: check status code and do not parse pull query error message
  • PR-10153 - Revert “Upgrade Antlr to 4.13.1 (#10122)”
  • PR-10138 - fix: make SR dependency optional
  • PR-10122 - Upgrade Antlr to 4.13.1
  • PR-10365 - add cp-jar-build tasks when running pr workflows

REST Proxy

  • PR-1273 - KNET-15501 work around jackson databind string length limit
  • 774a275a - [skip ci] Copy CODEOWNERS from the default branch
  • 9674993c - Removing /tmp/confluent as the DSTDIR check from Makefile
  • PR-1249 - Add doLog parameter for KafkaRestConfig constructor
  • PR-1250 - Allow to set KafkaAvroSerializerConfig in KafkaRestConfig (#1229)
  • PR-1247 - DP-13727 Add CodeArtifact package paths to service.yml
  • PR-1241 - KNET-13992 Fix java.lang.ClassNotFoundException: org.xerial.snappy.SnappyInputStream
  • PR-1228 - KREST-9993 Migrate integration tests to kraft
  • PR-1229 - KREST-12797 Allow to set KafkaAvroSerializerConfig in KafkaRestConfig
  • PR-1216 - Update service.yml
  • f7da1047 - Checking if removing the comment helps this pass in the upstream build
  • 6b994366 - Disabling flakey test
  • 3ac1df6b - Fix flakey test similar to
  • 611dfcc1 - [skip ci] Copy CODEOWNERS from the default branch
  • PR-482 - Do not throw ConfigException in case there are different applications configured for the server
  • ab8cd6a2 - Revert “Support HTTP/2 for BouncyCastle FIPS enabled (#472)”
  • PR-475 - KNET-14372 Getter for doLog and add helper config method
  • PR-472 - Support HTTP/2 for BouncyCastle FIPS enabled
  • 610c421a - ppv2
  • PR-469 - Add comment about keeping SslFactoryTest and SslFactoryFipsTest tests insync
  • bbca00ae - Remove test jar dependency from fips-tests module
  • PR-464 - Add doLog param for constructor
  • PR-462 - DP-13727 Add CodeArtifact package paths to service.yml
  • 05f2a0ab - Moved bc fips libs from main pom.xml to fips-tests.
  • 83d4def9 - Removed test scope from bc fips libs as they are needed downstream as compile.
  • 5fe66853 - Incorporated review comments.
  • 609b0547 - Added FIPS provider to cert/key factories.
  • 08af5745 - Removed unrequired deps from fips-tests/pom.xml.
  • f2f1ba00 - Added licenses.
  • 6d3a692e - Incorporated comments.
  • 4f0d2f69 - Updated test.
  • 2626f610 - removed semaphore debug
  • e67d7818 - Added debug to semaphore file.
  • 52534d9c - Fixed checkstyle issues.
  • 756e6fec - Fixed bug in reload test. Added variable to track load exception.
  • f6db4eaa - Added log4j dependencies to fips-tests.
  • 27d52376 - Added resources in both rest-utils and fips-tests.
  • 0b2f7d4d - Moved non fips tests to rest-utils/core and kep FIPS in fips-tests.
  • 1a858da5 - Fixed indentation
  • 6a4841de - Added separate module for fips tests.
  • ff6210a1 - Uncommented scala dependency.
  • b3831d47 - Removed ce-kafka:DefaultSslEngineFactory dependency.
  • 697f1045 - Completed unit tests.
  • b5520893 - More tests.
  • 63252c43 - Added FIPS test and bc fips deps in pom.xml.
  • 886a6245 - Moved certs and keys to static resources folder.
  • cec704b1 - Added basic tests and some refactoring.
  • 3f53dbe9 - Encapsulated PEM realted code in separate class. Incorporated comments.
  • c5a5308b - KSECURITY-2171: Added support for PEM based keystore.
  • PR-458 - Set nodeLabel for nightly master build
  • 2ebbbca3 - KREST-13506 Ensure we log timeout errors that result in a 500 error
  • 553d5691 - Update service.yml
  • PR-447 - KREST-11856 Correctly registry listener to the application’s NetworkTrafficServerConnector connector
  • 8d314dab - add test for cipher with incompatible protocol
  • e26c7c0c - add a comment
  • bd0f3937 - test cleanup
  • f8351ec2 - Add test for restricting SSL cipher suite
  • ac6ea86f - remove dead whitespace
  • 0f92d9f1 - KREST-12628 only log exceptions for 5xx
  • PR-430 - Update service.yml

Schema Registry

  • b1692037 - Revert recent change to in-memory cache
  • ab26883a - DGS-11418 Ensure aliases are properly qualified
  • b862eb19 - fix merge issue
  • 6a9d6e22 - Fix Protobuf custom option for single-entry map
  • b7aea93c - Incorporate review feedback
  • 2d3c4736 - Revert “do not reinstantiate objectmapper as it’s expensive (#2686) (#2695)”
  • 99e176a0 - Enhance test
  • b3570725 - Fix checkstyle
  • 18865846 - DGS-11418 Add aliases query param to /schemas endpoint
  • PR-3147 - DGS-12288 pt 2: Added config for calling local store on health check
  • cdf34e52 - DGS-12608 Fix deserialization of Avro unions with logical types
  • 9f34f1a4 - DGS-11418 Add aliases query param to schemas endpoint
  • PR-3142 - DGS-12288: Call kafkaStore on healthy checks
  • fbe1f760 - Fix build due to Jackson upgrade to 2.16
  • 0e4552fe - [skip ci] Copy CODEOWNERS from the default branch
  • 75f07a5f - update azure-identity
  • 026c2b1f - DGS-11833 Add API to return KEK names for a subject
  • 2c980a77 - More robust usage of ServiceLoader
  • 79d50b79 - Add comment
  • c9956f29 - ensure KafkaStoreMessageHandler take checkpoints
  • 2c6c783c - DGS-11554 Enhance Avro error with type name
  • f98a7075 - Fix checkstyle
  • d81d0f49 - Unwrap IllegalStateException if possible
  • ca36c3e3 - Add testSharing query param during kek create and update
  • fdc39bff - DGS-10707 Fix handleDeleteSubject to pass right oldSchemaValue
  • 8052b8a5 - expose sslfactory
  • 811adc50 - fix compile error
  • a3e3f2f8 - allow exception to be thrown
  • 5848374c - fix checkstyle
  • 01dbcbb9 - add headerProperties
  • de17bc6e - Support passing keystore/truststore to Vault KMS client
  • PR-3110 - Revert jackson to 2.14.2
  • PR-3109 - DGS-10892: Produce register schema message after tombstones
  • d6b8fcc0 - address review comment
  • 5ec016d9 - fix naming
  • 57dcf5bc - fix check style
  • d8cd6216 - Fix circular recursive reference
  • 33dd09be - add JettyEofExceptionWriterInterceptor to catch and swallow JettyEofException
  • cf034df4 - add JettyEofExceptionMapper to catch and convert JettyEofException to 400 error
  • 40f80bde - DGS-10920 Enhance register API to allow tags to be added/removed
  • 57308f0b - upgrade jackson package to fix build
  • 642def9c - DGS-10855 Fix inconsisteny with resolving recuring reference.
  • c3520a33 - Removing /tmp/confluent as the DSTDIR check from Makefile
  • PR-3098 - Fix build due to Jackson upgrade to 2.16.2
  • 403302ef - Fix build due to Jackson upgrade to 2.16.2
  • a128fcf5 - Add comment
  • 8e9c12cb - Fix NPE
  • dbd05f8c - DGS-10840 Ensure subject is hard deleted before clearing
  • fa9545cc - Ensure consistent lookup of rule params
  • b36c62ae - DGS-10808 Support const in JSONSchemaConverter
  • 2c32a50d - Refactor storage value to entity conversions
  • c04c8fbd - Revert “Minor renaming”
  • 8eeaf335 - Add disabled override
  • 93d8d2f8 - Allow rule onFailure/onSuccess to be overriden by rule type
  • 439119b5 - Add KEK test endpoint for testing shared KEKs
  • 4d377d80 - DGS-10135 Allow rule onFailure/onSuccess to be overriden via props
  • PR-3072 - DGS-10608: Don’t allow subjects named __EMPTY
  • af548bf0 - Update Apache commons-compress to 1.26.1
  • c0cbc3c8 - Add test
  • fce6aaf6 - Ensure sensitive values are decoded during listVersionsForId
  • 01d8b72b - DGS-10533 Fix NPE in deser when use.latest=true and RecordNameStrategy
  • e5f0e83f - enable topic deletion in tests
  • aab7e57f - DGS-10517 Scrub Avro namespace when scrub.invalid.names=true
  • PR-3059 - fix: nested schemas were not considered in matching the correct Json Union schema
  • PR-3056 - Fix build breakage caused by dependency change
  • 38e98145 - DGS-10394 Handle nulls in enum in JSON Schema converter
  • eed8a24f - Add REST APIs
  • 08db10e8 - Update service.yml
  • b28bf6c2 - Fix checkstyle
  • a54972f1 - fix checkstyle
  • d60862f1 - First cut at parsing tags
  • eefeee7a - First cut at 2020-12 $defs
  • 78ae7f7b - Fix merge issue
  • c84f735e - Update client/src/main/java/io/confluent/kafka/schemaregistry/rules/RuleContext.java
  • PR-3038 - feat: Added ReferenceSchema support to allOf
  • 578ef940 - Add missing import
  • 8257085e - unit test for reference schema inside allOf
  • 2808930e - DGS-10324 Add test to register same schema with no ID in IMPORT mode
  • fb094344 - Remove deprecated class
  • 317c4e89 - Upgrade json-skema to 0.13.0
  • d6179308 - feat: Added ReferenceSchema support to allOf
  • ae0e3140 - fix: invalid behaviour for stringSchema in allOfToConnectSchema
  • ad7a202a - fix: invalid behaviour for stringSchema in allOfToConnectSchema
  • 296b3780 - #3025 log error message with more details in case latest.compatibility.strict=true and latestVersion is not backward compatible
  • 6dcb41f7 - Fix tests
  • 6a138838 - Allow exact same schema to be re-imported
  • 814141db - Update ProtobufSchema.java
  • 885098ab - Update JsonSchema.java
  • ff5b2158 - DGS-10721 Add support for CONDITION with CEL_FIELD
  • a349821f - add OffsetCheckpointReadOnly
  • 22f36f3f - Optimization: cache Tink primitives
  • 8b8eebe0 - Fix checkstyle
  • 1063bb4c - Add check for FieldRuleExecutor
  • bc194452 - Add a CEL test with a tags expr in the guard
  • ff0b820b - Ensure specific Avro type is setup during configure
  • 6df56c8f - Optimization: remove known deps from ProtobufSchema
  • 16214b96 - Re-add schema parameter that was dropped during refactor
  • d6095ad3 - Fix checkstyle
  • 343ddff3 - First commit
  • PR-3012 - Minor: Apply service bot changes to earlier branches
  • 07c9975e - DGS-10206 Fix handling of multitype JSON schemas for 2020-12
  • e5bfd011 - DGS-10203 Add JSON Schema converter config to ignore modern dialects
  • 306dd5c5 - Add error message for PACKAGE_CHANGED
  • 2861cd88 - Fix checkstyle
  • abbab267 - DGS-10184 Ensure package change for Protobuf is incompatible
  • 31c49cf7 - Update SR client to accpet SSL configs
  • 641a9bab - Fix checkstyle
  • d59f138d - Enhance healthy method
  • d86366ad - Clean up test
  • 151edc97 - Upgrade json skema lib
  • aed3b7d5 - Ensure correct GenericData is used
  • 26569386 - Optimization: remove extraneous KekInfo/DekInfo classes
  • be5c571b - Improve parameter handling in FieldEncryptionExecutor
  • 5d5fda18 - Fix use of non-absolute refs for JSON Schema
  • PR-2993 - DP-13727 Add CodeArtifact package paths to service.yml
  • 3bd1cdd5 - update common-compress
  • 77f4ed97 - Ensure Vault namespace is being passed
  • 98ffc914 - update azure-identity to match the version used in ce-kafka
  • 2ef767e3 - Fix merge issue for wire upgrade
  • 7684230c - Update pom.xml
  • 2c3178f0 - .
  • 819d2c52 - .
  • 177af0d0 - DGS-10061 Add Protobuf compat check for moving field into existing oneOf
  • 60084a18 - .
  • PR-2969 - DGS-10046: Add health check for SR and extensions
  • 82f51da1 - Support older versions of Tink library
  • 2e8eaceb - .
  • 1813e4c2 - .
  • bbe261f4 - exclude okio
  • PR-2957 - Added snappy-java dependency
  • 3462d02f - Update commons-compress to 1.25.0
  • 30de64db - Fix breaking change ti ParsedSchema.validate method
  • c53b8f00 - Improve the performance of invalid name scrubbing
  • PR-2923 - Handle bug where enable.fips config is true but FIPS resource extension class is not configured
  • 83570cf5 - add configs
  • 6d8f0530 - Remove temp build fix
  • 0f4860f3 - Revert “Upgrade JSONata dependency to 2.5.0”
  • bd9d64f8 - Fix alias search when using context wildcard
  • 64e420b4 - Clean up LocalKmsClient
  • 2e6d4af6 - Upgrade json-skema dependency to 0.15.0
  • 8c5aaa96 - Upgrade JSONata dependency
  • 40691a19 - Add flatten.singleton.unions for JSON schema converter
  • 93db043a - Fix javadoc annotations to have no errors
  • e0b71df3 - Flatten singleton unions in Avro converter
  • 7917b812 - Fix dek search
  • eb059309 - Fix comparator for DataEncryptionKeyId
  • c025d150 - Fix comparator for DataEncryptionKeyId
  • 07ea0e03 - Add DekRegistry to SR properties for easier access
  • 79947071 - Cache checkpoint for cacheInitialized before reader thread starts