Confluent Platform Component Changelogs

This topic provides changelogs for the individual Confluent Platform components.

Version 7.6.0

Released February 2024

Community Features

Common

  • e99d8b1a - Exclude logback-core and logback-classic in line with the changes in kafka-rest
  • eb200670 - Update zookeeper component to match version in ce-kafka
  • 8e71caf2 - Update bouncycastle
  • 9862a1ce - Disable retirejs
  • 91d80f1d - Update pom.xml
  • 970d8055 - Upgrade Avro
  • 35a1415d - Update Jetty and Netty
  • 81295738 - Update snappy to 1.10.5
  • 90952027 - Update reload4j, fix typo
  • aea31af8 - Add guava to dependencyManagement

Kafka

  • PR-15291 - Update jetty to 9.4.53.v20231009
  • PR-15199 - KAFKA-16139: Fix StreamsUpgradeTest (#15199)
  • b743f6fd - KAFKA-16126: Kcontroller dynamic configurations may fail to apply at startup
  • 7486223d - KAFKA-16120: Fix partition reassignment during ZK migration
  • PR-15177 - KAFKA-16017: Checkpoint restored offsets instead of written offsets (#15177)
  • PR-15149 - KAFKA-16093: Fix spurious REST-related warnings on Connect startup (#15149)
  • PR-14980 - KAFKA-15817: Avoid reconnecting to the same IP address (#14813) (#14980)
  • PR-15090 - KAFKA-16065: close DelayedFuturePurgatory in DelayedOperationTest (#15090)
  • PR-15079 - KAFKA-16053: Fix memory leaks due to KDC server in tests (#15079)
  • PR-15007 - KAFKA-16007: Merge batch records during ZK migration (#15007)
  • PR-14293 - KAFKA-15372: Reconfigure dedicated MM2 connectors after leadership change (#14293)
  • PR-14567 - KAFKA-13988: Enable replicating from latest offset with MirrorMaker 2 (#14567)
  • 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-987 - KSECURITY-2090: Updated bcpkix version to 1.77
  • PR-14719 - KAFKA-15799 Handle full metadata updates on ZK brokers (#14719)
  • 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-14635 - KAFKA-15755: LeaveGroupResponse v0 - v2 loses its member under certain error conditions (#14635)
  • 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-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-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-14674 - KAFKA-15771: fix concurrency bug in ProduceRequest#partitionSizes() (#14674)
  • PR-14630 - KAFKA-15680: Fix sink task partition-count metric when cooperative consumer protocol is used (#14630)
  • 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-14601 - KAFKA-15664: Add 3.4 Streams upgrade system tests (#14601)
  • PR-14539 - KAFKA-15378: fix streams upgrade system test (#14539)
  • PR-14587 - KAFKA-15607: Fix NPE in MirrorCheckpointTask::syncGroupOffset (#14587)
  • 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-14535 - KAFKA-15596: Upgrade ZooKeeper to 3.8.3 (#14535)
  • PR-14519 - KAFKA-15571: StateRestoreListener#onRestoreSuspended is never called because DelegatingStateRestoreListener doesn’t implement onRestoreSuspended (#14519)
  • 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-14445 - KAFKA-15502: Update SslEngineValidator to handle large stores (#14445)
  • PR-14480 - KAFKA-15330: Add missing documentation of metrics introduced as part of KAFKA-15028 (#14480)
  • PR-14459 - KAFKA-15511: Handle CorruptIndexException in RemoteIndexCache (#14459)
  • PR-14434 - KAFKA-15498: bump snappy-java version to 1.1.10.4 (#14434)
  • PR-14398 - KAFKA-15473: Hide duplicate plugins in /connector-plugins (#14398)
  • PR-14393 - Added missing licenses for libraries (#14393)
  • 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-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-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-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-14340 - KAFKA-15351: Update log-start-offset after leader election for topics enabled with remote storage (#14340)
  • 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-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-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-14319 - KAFKA-15427: Fix resource leak in integration tests for tiered storage (#14319)
  • PR-14301 - KAFKA-15351: Ensure log-start-offset not updated to local-log-start-offset when remote storage enabled (#14301)
  • daea0fdf - KAFKA-15375: fix broken clean shutdown detection logic in LogManager
  • PR-14161 - KAFKA-15267: Do not allow Tiered Storage to be disabled while topics have remote.storage.enable property (#14161)
  • PR-14285 - KAFKA-15399: Enable OffloadAndConsumeFromLeader test (#14285)
  • 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-14238 - KAFKA-15290: Handle topic-level dynamic remote storage enable configuration (#14238)
  • PR-14283 - KAFKA-15400: Use readLock when removing an item from the RemoteIndexCache (#14283)
  • PR-14135 - KAFKA-14991: KIP-937-Improve message timestamp validation (#14135)
  • PR-14280 - KAFKA-15391: Handle concurrent dir rename which makes log-dir to be offline unexpectedly (#14280)
  • PR-14208 - KAFKA-14538 Metadata transactions in MetadataLoader (#14208)
  • PR-14269 - KAFKA-14936: fix grace period partition issue (#14269)
  • PR-14197 - KAFKA-15380: Execute action queue after callback request (#14197)
  • PR-14116 - KAFKA-15167: Tiered Storage Test Harness Framework (#14116)
  • PR-14083 - KAFKA-15219: KRaft support for DelegationTokens (#14083)
  • PR-14249 - KAFKA-10199: Change to RUNNING if no pending task to init exist (#14249)
  • PR-938 - KSECURITY-1789: upgrading requests to v2.31.0
  • PR-14027 - KAFKA-14936: Add restore logic (3/N) (#14027)
  • PR-14230 - KAFKA-15226: Add connect-plugin-path and plugin.discovery system test (#14230)
  • PR-14103 - HOTIFX: fix Kafka Streams upgrade path from 3.4 to 3.5 (#14103)
  • PR-14237 - Handle case of default broker in config migration (#14237)
  • PR-14216 - KAFKA-15319: Upgrade rocksdb
  • PR-13947 - KAFKA-15130: Delete remote segments when deleting a topic (#13947)
  • PR-936 - KSECURITY-1859: upgrading netty to 4.1.96.Final
  • PR-14213 - KAFKA-15345; KRaft leader notifies leadership when listener reaches epoch start (#14213)
  • PR-14220 - KAFKA-15102: Add release notes about the replication.policy.internal.topic.separator.enabled property for MirrorMaker 2 (#14220)
  • PR-14005 - KAFKA-15177: Implement KIP-875 SourceConnector::alterOffset API in MirrorMaker 2 connectors (#14005)
  • PR-14195 - KAFKA-15228: Add sync-manifests command to connect-plugin-path (KIP-898) (#14195)
  • PR-13302 - KAFKA-14759: Move Mock, Schema, and Verifiable connectors to new test-plugins module (#13302)
  • PR-14183 - KAFKA-15210: Mention vote should be open for at atleast 72 hours in the release script (#14183)
  • PR-14209 - KAFKA-14133: Migrate ActiveTaskCreatorTest, ChangelogTopicsTest and GlobalProcessorContextImplTest to Mockito (#14209)
  • PR-14142 - KAFKA-7438: Replace EasyMock with Mockito in SessionStoreBuilderTest (#14142)
  • PR-14205 - KAFKA-14133: Migrato SessionCacheFlushListenerTest, TimestampedCacheFlushListenerTest and TimestampedTupleForwarderTest to Mockito (#14205)
  • PR-14202 - KAFKA-15329: Make default remote.log.metadata.manager.class.name as topic based RLMM (#14202)
  • PR-14082 - KAFKA-15102: Add replication.policy.internal.topic.separator.enabled property to MirrorMaker 2 (KIP-949) (#14082)
  • PR-14176 - KAFKA-15295: Add config validation when remote storage is enabled on a topic (#14176)
  • PR-14190 - KAFKA-7438: Replace Easymock & Powermock with Mockito in RocksDBMetricsRecorderGaugesTest (#14190)
  • adc16d0f - KAFKA-14538: Implement KRaft metadata transactions in QuorumController
  • PR-13990 - KAFKA-14937: Refactoring for client code to reduce boilerplate (#13990)
  • PR-14001 - KAFKA-15326: [5/N] Processing thread punctuation (#14001)
  • PR-14201 - KAFKA-15289: Support KRaft mode in RequestQuotaTest (#14201)
  • PR-14189 - KAFKA-7438: Replace Easymock & Powermock with Mockito in TableSourceNodeTest (#14189)
  • PR-14064 - KAFKA-15030: Add connect-plugin-path command-line tool (#14064)
  • PR-14187 - KAFKA-13197: fix GlobalKTable join/left-join semantics documentation. (#14187)
  • PR-14172 - KAFKA-14595: Move classes from ReassignPartitionsCommand to tools (#14172)
  • PR-14153 - KAFKA-14132: Replace Easymock & Powermock with Mockito in KafkaBasedLogTest (#14153)
  • PR-14151 - KAFKA-15083: add config with “remote.log.metadata” prefix (#14151)
  • PR-14185 - KAFKA-15287: Change NodeApiVersions.create() to support both zk and kraft (#14185)
  • PR-14188 - KAFKA-15239: Fix ThroughputThrottler import-control (#14188)
  • PR-14068 - KAFKA-15233: Add documentation for plugin.discovery and connect-plugin-path (KIP-898) (#14068)
  • PR-14092 - KAFKA-15239: Fix system tests using producer performance service (#14092)
  • PR-14102 - KAFKA-13187: Replace EasyMock / PowerMock with Mockito in DistributedHerderTest (#14102)
  • PR-14156 - KAFKA-15202: Fix MM2 offset translation when syncs are variably spaced (#14156)
  • PR-14050 - KAFKA-15220: Do not returned fenced brokers from getAliveBrokerNode (#14050)
  • PR-14159 - KAFKA-15291: Connect plugins should declare a version (#14159)
  • PR-14169 - KAFKA-15318: Update the Authorizer via AclPublisher (#14169)
  • PR-14175 - KAFKA-15288: Change BrokerApiVersionsCommandTest to support kraft mode (#14175)
  • PR-14178 - KAFKA-15022: [9/N] use RackAwareTaskAssignor in StickyTaskAssignor (#14178)
  • PR-14164 - KAFKA-15022: [8/N] more tests for HAAssignor (#14164)
  • PR-14141 - KAFKA-15100; KRaft data race with the expiration service (#14141)
  • PR-14096 - KAFKA-14595: Move AdminUtils to server-common (#14096)
  • PR-14125 - KAFKA-15271: Historicalterator can exposes elements that are too new (#14125)
  • PR-14162 - KAFKA-15312; Force channel before atomic file move (#14162)
  • PR-14055 - KAFKA-15031: Add plugin.discovery to Connect worker configuration (KIP-898) (#14055)
  • PR-14139 - KAFKA-15022: [7/N] use RackAwareTaskAssignor in HAAssignor (#14139)
  • PR-14150 - KAFKA-15022: [6/N] add rack aware assignor configs and update standby optimizer (#14150)
  • PR-14133 - KAFKA-15189: only init remote topic metrics when enabled (#14133)
  • PR-13984 - KAFKA-15107: Support custom metadata for remote log segment (#13984)
  • PR-14145 - KAFKA-10199: Change to RUNNING if no pending task to recycle exist (#14145)
  • PR-13920 - KAFKA-15106: Fix AbstractStickyAssignor isBalanced predict (#13920)
  • PR-14143 - KAFKA-7438: Replace PowerMockRunner with MockitoJUnitRunner in RetryUtilTest (#14143)
  • PR-14114 - KAFKA-12969: Add broker level config synonyms for topic level tiered storage configs (#14114)
  • PR-14108 - KAFKA-15022: [5/N] compute rack aware assignment for standby tasks (#14108)
  • PR-14074 - KAFKA-15236: Rename tiered storage metrics (#14074)
  • PR-14128 - KAFKA-15272: Fix the logic which finds candidate log segments to upload it to tiered storage (#14128)
  • PR-14097 - KAFKA-15022: [4/N] use client tag assignor for rack aware standby task assignment (#14097)
  • PR-14089 - KAFKA-15244: Remove PluginType.from(Class) (#14089)
  • PR-13260 - KAFKA-14661: Upgrade Zookeeper to 3.8.1 (#13260)
  • PR-14126 - Fix a Scala 2.12 compile issue (#14126)
  • PR-14099 - KAFKA-14702: Extend server side assignor to support rack aware replica placement (#14099)
  • PR-14115 - KAFKA-15263 Check KRaftMigrationDriver state in each event (#14115)
  • PR-14056 - KAFKA-14501: Implement Heartbeat protocol in new GroupCoordinator (#14056)
  • PR-14090 - KAFKA-14048; CoordinatorContext should be protected by a lock (#14090)
  • PR-13671 - KAFKA-14967: fix NPE in CreateTopicsResult in MockAdminClient (#13671)
  • PR-14049 - KAFKA-14038: Optimise calculation of size for log in remote tier (#14049)
  • PR-13643 - KAFKA-15213: provide the exact offset to QuorumController.replay (#13643)
  • PR-14084 - [MINOR] Add latest versions to kraft upgrade kafkatest (#14084)
  • PR-14067 - KAFKA-14499: [3/N] Implement OffsetCommit API (#14067)
  • PR-14069 - KAFKA-15251: Add 3.5.1 to system tests (#14069)
  • PR-14017 - KAFKA-14500; [6/6] Implement SyncGroup protocol in new GroupCoordinator (#14017)
  • PR-14030 - KAFKA-15022: [3/N] use graph to compute rack aware assignment for active stateful tasks (#14030)
  • PR-14075 - KAFKA-15235: Fix broken coverage reports since migration to Gradle 8.x (#14075)
  • PR-14028 - KAFKA-15196 Additional ZK migration metrics (#14028)
  • PR-14094 - KAFKA-15243: Set decoded user names to DescribeUserScramCredentialsResponse (#14094)
  • PR-14100 - [MINOR] Fix Javadoc comment in KafkaFuture#toCompletionStage (#14100)
  • PR-14059 - KAFKA-14583: Move ReplicaVerificationTool to tools (#14059)
  • PR-14051 - KAFKA-15218: Avoid NPE thrown while deleting topic and fetch from follower concurrently (#14051)
  • PR-14079 - KAFKA-15238: Move DLQ reporter setup from the DistributedHerder’s tick thread to the sink task thread (#14079)
  • PR-14010 - KAFKA-15183: Add more controller, loader, snapshot emitter metrics (#14010)
  • PR-13707 - KAFKA-14990: Dynamic producer ID expiration should be applied on a broker restart (#13707)
  • PR-14033 - KAFKA-14920: Address timeouts and out of order sequences (#14033)
  • PR-14004 - KAFKA-15168: Handle overlapping remote log segments in RemoteLogMetadata cache (#14004)
  • PR-13773 - KAFKA-14712: Produce correct error msg with correct metadataversion (#13773)
  • PR-14057 - KAFKA-15194: Prepend offset in the filenames used by LocalTieredStorage (#14057)
  • PR-13797 - KAFKA-14950: implement assign() and assignment() (#13797)
  • PR-14066 - KAFKA-15232: Move ToolsUtils to tools (#14066)
  • PR-14047 - KAFKA-14499: [2/N] Add OffsetCommit record & related (#14047)
  • PR-14046 - KAFKA-14499: [1/N] Introduce OffsetCommit API version 9 and add new StaleMemberEpochException error (#14046)
  • PR-14024 - KAFKA-13431 (KIP-793): Expose the original pre-transform topic partition and offset in sink records (#14024)
  • PR-13278 - KAFKA-14591: Move DeleteRecordsCommand to tools (#13278)
  • PR-14060 - KAFKA-15222: upgrade zinc scala plugin to 1.9.2 (#14060)
  • PR-13999 - KAFKA-15176: add tests for tiered storage metrics (#13999)
  • PR-13996 - KAFKA-15022: [2/N] introduce graph to compute min cost (#13996)
  • PR-13313 - KAFKA-14760: Move ThroughputThrottler from tools to clients, remove tools dependency from connect-runtime (#13313)
  • PR-13874 - KAFKA-14133: Migrate various mocks in TaskManagerTest to Mockito (#13874)
  • PR-14044 - KAFKA-15216: InternalSinkRecord::newRecord should not ignore new headers (#14044)
  • PR-13942 - KAFKA-14936: Check the versioned table’s history retention and compare to grace period (4/N) (#13942)
  • PR-13983 - KAFKA-14734: Use CommandDefaultOptions in StreamsResetter (#13983)
  • PR-13971 - KAFKA-15150: Add ServiceLoaderScanner implementation (#13971)
  • PR-14029 - KAFKA-10579: Upgrade reflections from 0.9.12 to 0.10.2 (#14029)
  • PR-13977 - KAFKA-15162: Reflectively find plugins in parent ClassLoaders that aren’t on the classpath (#13977)
  • PR-13949 - KAFKA-15141: Initialize logger statically on hot codepaths (#13949)
  • PR-14039 - KAFKA-15211: Mock InvalidParameterException in DistributedConfigTest (#14039)
  • PR-14035 - KAFKA-15199: Remove Leading and Trailing Spaces in release.py (#14035)
  • PR-13870 - KAFKA-14500; [5/N] Implement JoinGroup protocol in new GroupCoordinator (#13870)
  • PR-13948 - KAFKA-15091: Fix misleading Javadoc for SourceTask::commit (#13948)
  • PR-13944 - KAFKA-14953: Add tiered storage related metrics (#13944)
  • PR-13945 - KAFKA-15121: Implement the alterOffsets method in the FileStreamSourceConnector and the FileStreamSinkConnector (#13945)
  • PR-13585 - KAFKA-14737: Move kafka.utils.json to server-common (#13585)
  • PR-13158 - KAFKA-14647: Move TopicFilter to server-common/utils (#13158)
  • PR-13837 - KAFKA-9564: Local Tiered Storage implementation for Remote Storage Manager (#13837)
  • PR-14023 - fix typo in streams/dsl-api.html (#14023)
  • PR-13941 - KAFKA-15123: Add tests for ChunkedBytesStream (#13941)
  • PR-13787 - KAFKA-14884: Include check transaction is still ongoing right before append (take 2) (#13787)
  • PR-14003 - KAFKA-15182: Normalize source connector offsets before invoking SourceConnector::alterOffsets (#14003)
  • PR-13991 - KAFKA-14462; [23/23] Wire GroupCoordinatorService in BrokerServer (#13991)
  • PR-13997 - KAFKA-15180: Generalize integration tests to change use of KafkaConsumer to Consumer (#13997)
  • PR-14013 - Fix compile test error (#14013)
  • PR-10167 - KAFKA-12261: Mention about potential delivery loss on increasing partition when auto.offset.reset = latest (#10167)
  • PR-13957 - Kafka Streams Threading: Exception handling (#13957)
  • PR-13973 - KAFKA-15148: Mark tests correctly as integration tests where they running as unit tests (#13973)
  • PR-13963 - KAFKA-14462; [22/N] Implement session and revocation timeouts (#13963)
  • PR-13859 - KAFKA-15093: Add 3.4.0 and 3.5.0 to core upgrade and compatibility system tests (#13859)
  • PR-13275 - KAFKA-14522 Rewrite/Move of RemoteIndexCache to storage module. (#13275)
  • PR-13453 - KAFKA-12525: Ignoring stale status statuses when reading from Connect status topic (#13453)
  • PR-13974 - KAFKA-15155: Follow PEP 8 best practice in Python to check if a container is empty (#13974)
  • PR-13988 - [KAFKA-15137] Do not log entire request payload in KRaftControllerChannelManager (#13988)
  • PR-13982 - KAFKA-15159: upgrade minor dependencies (#13982)
  • PR-13946 - KAFKA-15139: Avoid slow Set.removeAll(List) in MirrorCheckpointConnector (#13946)
  • PR-13955 - KAFKA-15145: Don’t re-process records filtered out by SMTs on Kafka client retriable exceptions in AbstractWorkerSourceTask (#13955)
  • PR-13383 - KAFKA-14059 Replace PowerMock with Mockito in WorkerSourceTaskTest (#13383)
  • PR-13284 - KAFKA-14718: Wait for MirrorMaker to start before executing test (#13284)
  • PR-13661 - Doc fixes: Fix format and other small errors in config documentation (#13661)
  • PR-13851 - KAFKA-15022: [1/N] initial implementation of rack aware assignor (#13851)
  • PR-13961 - KAFKA-14462; [21/N] Add CoordinatorTimer implementation in CoordinatorRuntime (#13961)
  • PR-13968 - KAFKA-15149: Fix handling of new partitions in dual-write mode (#13968)
  • PR-13962 - KAFKA-15129;[7/N] Remove metrics in TransactionMarkerChannelManager when TransactionCoordinator shutdown (#13962)
  • PR-13821 - KAFKA-15069: Refactor plugin scanning logic into ReflectionScanner (#13821)
  • PR-13964 - KAFKA-15153: Use Python ‘is’ instead of ‘==’ to compare for None (#13964)
  • PR-13898 - KAFKA-14966; [2/N] Extract OffsetFetcher reusable logic (#13898)
  • PR-13901 - KAFKA-14462; [20/N] Refresh subscription metadata on new metadata image (#13901)
  • PR-13950 - KAFKA-15140: Use TestUtils methods and add logs for assertion failure at TopicCommandIntegrationTest (#13950)
  • PR-13925 - KAFKA-10199: Consider tasks in state updater when computing offset sums (#13925)
  • PR-13924 - KAFKA-15129: [1/N] Remove metrics in LogCleanerManager when LogCleaner shutdown (#13924)
  • PR-13938 - KAFKA-15135: fix(storage): pass endpoint configurations as client common to TBRLMM (#13938)
  • PR-13760 - KAFKA-8982: Add retry of fetching metadata to Admin.deleteRecords (#13760)
  • PR-13939 - [MINOR] Correcting few WARN log lines in DistributedHerder#handleRebalance (#13939)
  • PR-13923 - KAFKA-15131: Improve RemoteStorageManager exception handling documentation (#13923)
  • PR-13591 - KAFKA-14831: Illegal state errors should be fatal in transactional producer (#13591)
  • PR-13904 - KAFKA-15114: Update StorageTool help for creating SCRAM credentials to specify name instead of user. (#13904)
  • PR-13915 - KAFKA-14930: Document the new PATCH and DELETE offsets REST APIs for Connect (#13915)
  • PR-13855 - KAFKA-14936: Add Grace period logic to Stream Table Join (2/N) (#13855)
  • PR-13831 - KAFKA-15053: Use case insensitive validator for security.protocol config (#13831)
  • PR-13880 - KAFKA-14462; [19/N] Add CoordinatorLoader implementation (#13880)
  • PR-13845 - KAFKA-15078; KRaft leader replys with snapshot for offset 0 (#13845)
  • PR-13798 - KAFKA-15028: AddPartitionsToTxnManager metrics (#13798)
  • PR-13910 - KAFKA-15109 Ensure the leader epoch bump occurs for older MetadataVersions (#13910)
  • PR-907 - Fix packaging master build
  • PR-13818 - KAFKA-14784: Connect offset reset REST API (#13818)
  • PR-13267 - KAFKA-14694: RPCProducerIdManager should not wait on new block (#13267)
  • PR-13895 - KAFKA-15098 Allow authorizers to be configured in ZK migration (#13895)
  • PR-13812 - KAFKA-14462; [18/N] Add GroupCoordinatorService (#13812)
  • PR-13890 - KAFKA-15109 Don’t skip leader epoch bump while in migration mode (#13890)
  • PR-13850 - KAFKA-15084: Remove lock contention from RemoteIndexCache (#13850)
  • PR-13856 - KAFKA-15087 Move/rewrite InterBrokerSendThread to server-commons (#13856)
  • PR-12739 - KAFKA-7438: Migrate to Mockito in TimeOrderedCachingPersistentWindowStoreTest (#12739)
  • cd3c0ab1 - KAFKA-15060: fix the ApiVersionManager interface
  • PR-13872 - KAFKA-15085: Make Timer.java implement AutoCloseable (#13872)
  • PR-13865 - KAFKA-15096: Update snappy-java to 1.1.10.1 (#13865)
  • PR-13828 - KAFKA-15066: add “remote.log.metadata.manager.listener.name” config to rlmm (#13828)
  • PR-13819 - KAFKA-15059: Remove pending rebalance check when fencing zombie source connector tasks (#13819)
  • PR-13711 - KAFKA-14133: Migrate StandbyTaskCreator mock in TaskManagerTest to Mockito (#13711)
  • PR-13756 - KAFKA-14936: Add On Disk Time Ordered Buffer (1/N) (#13756)
  • PR-902 - Update muckrake version mapping for 3.5
  • PR-13843 - KAFKA-15080; Fetcher’s lag never set when partition is idle (#13843)
  • PR-13712 - KAFKA-14133: Migrate Admin mock in TaskManagerTest to Mockito (#13712)
  • PR-13795 - KAFKA-14462; [17/N] Add CoordinatorRuntime (#13795)
  • PR-13834 - KAFKA-15076; KRaft should prefer latest snapshot (#13834)
  • PR-13832 - KAFKA-15036: Add a test case for controller failover (#13832)
  • PR-13829 - KAFKA-10199: Re-add revived tasks to the state updater after handling (#13829)
  • PR-13835 - KAFKA-15077: Code to trim token in FileTokenRetriever (#13835)
  • PR-13830 - KAFKA-14936: Change Time Ordered Buffer to not require Change<> 0/N (#13830)
  • PR-13827 - KAFKA-15073: Add a Github action to mark PRs as stale (#13827)
  • PR-13807 - KAFKA-15040: trigger onLeadershipChange under KRaft mode (#13807)
  • PR-13815 - KAFKA-14966: Extract OffsetFetcher reusable logic (#13815)
  • PR-12307 - KAFKA-14006: Parameterize WorkerConnectorTest suite (#12307)
  • PR-13751 - KAFKA-14539: Simplify StreamsMetadataState by replacing the Cluster metadata with partition info map (#13751)
  • PR-13811 - KAFKA-14278: Fix InvalidProducerEpochException and InvalidTxnStateException handling in producer clients (#13811)
  • PR-13803 - KAFKA-15051: add missing GET plugin/config endpoint (#13803)
  • PR-13678 - KAFKA-10337: await async commits in commitSync even if no offsets given (#13678)
  • PR-13765 - KAFKA-15021; Skip leader epoch bump on ISR shrink (#13765)
  • PR-13788 - KAFKA-14791; Create a builder for PartitionRegistration (#13788)
  • PR-13675 - KAFKA-14462; [14/N] Add PartitionWriter (#13675)
  • PR-13473 - KAFKA-14866: Remove controller module metrics when broker is shutting down (#13473)
  • PR-13135 - KAFKA-14633: Reduce data copy & buffer allocation during decompression (#13135)
  • PR-13779 - KAFKA-15037: pass remoteLogEnabled to unifiedLog (#13779)
  • PR-13805 - KAFKA-14863: Fix failing tests for invalid plugins that are no longer visible (#13805)
  • PR-13799 - KAFKA-15048: Improve handling of unexpected quorum controller errors (#13799)
  • PR-13794 - KAFKA-14462; [16/N] Add CoordinatorLoader and CoordinatorPlayback interfaces (#13794)
  • PR-13800 - KAFKA-15012: Allow leading zeros in numeric fields while deserializing JSON messages using the JsonConverter (#13800)
  • PR-13467 - KAFKA-14863: Hide plugins with invalid constructors during plugin discovery (#13467)
  • PR-13793 - KAFKA-14462; [15/N] Make Result generic and rename it (#13793)
  • PR-13759 - KAFKA-15019: Improve handling of broker heartbeat timeouts (#13759)
  • PR-13735 - KAFKA-15003: Fix ZK sync logic for partition assignments (#13735)
  • PR-13666 - KAFKA-14462; [13/N] CoordinatorEvent and CoordinatorEventProcessor (#13666)
  • PR-13776 - KAFKA-15034: Improve performance of the ReplaceField SMT; add JMH benchmark (#13776)
  • PR-13758 - KAFKA-15010 ZK migration failover support (#13758)
  • PR-13757 - KAFKA-15017 Fix snapshot load in dual write mode for ClientQuotas and SCRAM (#13757)
  • PR-13774 - KAFKA-12562: Fix KafkaStreams#store old references in comments (#13774)
  • PR-13681 - KAFKA-14133: Migrate ActiveTaskCreator mock in TaskManagerTest to Mockito (#13681)
  • PR-13786 - Upgrade to snappy v1.1.10.0 (#13786)
  • PR-13780 - KAFKA-15039: Reduce logging level to trace in PartitionChangeBuilder.… (#13780)
  • PR-13767 - KAFKA-15004: Fix configuration dual-write during migration (#13767)
  • PR-13781 - KAFKA-8713: JsonConverter replace.null.with.default should prevent emitting default for Struct fields (#13781)
  • PR-13639 - KAFKA-14462; [12/N] Add GroupMetadataManager and ConsumerGroup (#13639)
  • PR-13738 - KAFKA-14982: Improve the kafka-metadata-quorum output (#13738)
  • PR-13742 - KAFKA-14996: Handle overly large user operations on the kcontroller (#13742)
  • PR-13741 - KAFKA-15009: Handle new ACLs in KRaft snapshot during migration (#13741)
  • PR-13732 - KAFKA-15007: Use the correct MetadataVersion in MetadataPropagator (#13732)
  • PR-13729 - KAFKA-14970: Fix SCRAM during migration dual-write (#13729)
  • PR-13356 - KAFKA-14789: Prevent mis-attributing classpath plugins, allow discovery of classpath RestExtension and ConfigProvider (#13356)
  • PR-13465 - KAFKA-14368: Connect offset write REST API (#13465)
  • PR-13455 - KAFKA-14841 Handle callbacks to ConsumerRebalanceListener in MockConsumer (#13455)
  • PR-13664 - KAFKA-14961: harden DefaultBackgroundThreadTest.testStartupAndTearDown test (#13664)
  • PR-13165 - KAFKA-14654: Connector classes should statically initialize with plugin classloader (#13165)
  • PR-13749 - KAFKA-15016: Update LICENSE-binary file (#13749)
  • PR-11565 - KAFKA-13504: Retry connect internal topics’ creation in case of InvalidReplicationFactorException (#11565)
  • PR-13745 - KAFKA-15015: Explicit on reload4j version (#13745)
  • PR-13708 - KAFKA-14500; [4/N] Add Timer interface (#13708)
  • PR-13704 - KAFKA-14500; [3/N] add GroupMetadataKey/Value record helpers (#13704)
  • PR-13723 - KAFKA-14980: Fix MirrorSourceConnector source consumer configuration (#13723)
  • PR-13535 - KAFKA-9579 Fetch implementation for records in the remote storage through a specific purgatory. (#13535)
  • PR-13720 - KAFKA-14997: Fix JmxToolTest failing on CI server (#13720)
  • PR-13717 - KAFKA-14994: Update jose4j
  • PR-13670 - KAFKA-14962: Trim whitespace from ACL configuration (#13670)
  • PR-13663 - KAFKA-14500; [2/N] Rewrite GroupMetadata in Java (#13663)
  • PR-13679 - KAFKA-14291: KRaft controller should return right finalized features in ApiVersionResponse (#13679)
  • PR-13517 - KAFKA-14752: Kafka examples improvements - demo changes (#13517)
  • PR-13060 - KAFKA-14559: Fix JMX tool to handle the object names with wildcard and optional attributes (#13060)
  • PR-13690 - KAFKA-14978 ExactlyOnceWorkerSourceTask should remove parent metrics (#13690)
  • PR-13516 - KAFKA-14752: Kafka examples improvements - processor changes (#13516)
  • PR-13443 - KAFKA-14514; Add Range Assignor on the Server (KIP-848) (#13443)
  • PR-13660 - KAFKA-14662: Update the ACL list in the doc (#13660)
  • PR-13644 - KAFKA-14500; [1/N] Rewrite MemberMetadata in Java (#13644)
  • PR-13688 - KAFKA-14974: Restore backward compatibility in KafkaBasedLog (#13688)
  • PR-13638 - KAFKA-14462; [11/N] Add CurrentAssignmentBuilder (#13638)
  • PR-13594 - KAFKA-14913: Using ThreadUtils.shutdownExecutorServiceQuietly to close executors in Connect Runtime (#13594)
  • PR-13621 - KAFKA-14133: Migrate ChangeLogReader mock in TaskManagerTest to Mockito (#13621)
  • PR-13515 - KAFKA-14752: Kafka examples improvements - producer changes (#13515)
  • PR-13461 - KAFKA-14840: Support for snapshots during ZK migration (#13461)
  • PR-13312 - KAFKA-14766: Improve performance of VarInt encoding and decoding (#13312)
  • PR-13623 - KAFKA-14926: Remove metrics on Log Cleaner shutdown (#13623)
  • PR-13607 - KAFKA-14916: Fix code that assumes transactional ID implies all records are transactional (#13607)
  • PR-12149 - KAFKA-13668: Retry upon missing initProducerId due to authorization error (#12149)
  • PR-13122 - KAFKA-14594: Move LogDirsCommand to tools module (#13122)
  • PR-13628 - KAFKA-14859: SCRAM ZK to KRaft migration with dual write (#13628)
  • PR-13653 - KAFKA-14946: fix NPE when merging the deltatable (#13653)
  • PR-13657 - KAFKA-14876: Document the new ‘PUT /connectors/{name}/stop’ REST API for Connect (#13657)
  • PR-13637 - KAFKA-14462; [10/N] Add TargetAssignmentBuilder (#13637)
  • PR-13514 - KAFKA-14752: Kafka examples improvements - consumer changes (#13514)
  • PR-13529 - KAFKA-14133: Migrate topology builder mock in TaskManagerTest to mockito (#13529)
  • PR-13631 - KAFKA-14909: check zkMigrationReady tag before migration (#13631)
  • PR-13407 - KAFKA-14805 KRaft controller supports pre-migration mode (#13407)
  • PR-13550 - KAFKA-14639: A single partition may be revoked and assign during a single round of rebalance (#13550)
  • PR-13171 - KAFKA-14584: Deprecate StateChangeLogMerger tool (#13171)
  • PR-13606 - KAFKA-14918 Only send controller RPCs to migrating ZK brokers (#13606)
  • 33962e8b - KAFKA-14943: Fix ClientQuotaControlManager validation
  • 70493336 - KAFKA-14943: Fix ClientQuotaControlManager validation
  • PR-13544 - KAFKA-14462; [9/N] Add RecordHelpers (#13544)
  • PR-12545 - KAFKA-14944: Reduce CompletedFetch#parseRecord() memory copy (#12545)
  • PR-13429 - KAFKA-14666: Add MM2 in-memory offset translation index for offsets behind replication (#13429)
  • PR-13538 - KAFKA-14462; [8/N] Add ConsumerGroupMember (#13538)
  • PR-13636 - KAFKA-14933: Document Connect’s log level REST APIs from KIP-495 (#13636)
  • PR-13459 - KAFKA-14592: Move FeatureCommand to tools (#13459)
  • PR-13533 - KAFKA-12446: update change encoding to use varint (#13533)
  • PR-13615 - KAFKA-14834: [12/N] Minor code cleanups relating to versioned stores (#13615)
  • PR-13592 - KAFKA-14862: Outer stream-stream join does not output all results with multiple input partitions (#13592)
  • PR-13587 - KAFKA-14876: Document the new ‘GET /connectors/{name}/offsets’ REST API for Connect (#13587)
  • PR-13575 - KAFKA-14905: Reduce flakiness in MM2 ForwardingAdmin test due to admin timeouts (#13575)
  • PR-13537 - KAFKA-14462; [7/N] Add ClientAssignor, Assignment, TopicMetadata and VersionedMetadata (#13537)
  • PR-13437 - KAFKA-14828: Remove R/W locks using persistent data structures (#13437)
  • 3f1e78ee - KAFKA-14887: FinalizedFeatureChangeListener should not shut down when ZK session expires
  • PR-13579 - KAFKA-14904: Pending state blocked verification of transactions (#13579)
  • PR-13614 - KAFKA-14586: Adding redirection for StreamsResetter (#13614)
  • PR-13432 - KAFKA-14821 Implement the listOffsets API with AdminApiDriver (#13432)
  • f5de4daa - KAFKA-14887: FinalizedFeatureChangeListener should not shut down when ZK session expires
  • PR-13609 - KAFKA-14834: [11/N] Update table joins to identify out-of-order records with isLatest (#13609)
  • PR-11478 - KAFKA-13299: Accept duplicate listener on port for IPv4/IPv6 (#11478)
  • PR-13471 - KAFKA-14868: Remove all ReplicaManager metrics when it is closed (#13471)
  • PR-13572 - KAFKA-14908: Set setReuseAddress on the kafka server socket (#13572)
  • PR-13513 - KAFKA-14881: Rework UserScramCredentialRecord (#13513)
  • PR-13526 - KAFKA-14869: Bump coordinator value records to flexible versions (KIP-915, Part-2) (#13526)
  • PR-13511 - KAFKA-14869: Ignore unknown record types for coordinators (KIP-915, Part-1) (#13511)
  • PR-13557 - KAFKA-14902: KafkaStatusBackingStore retries on a dedicated background thread to avoid stack overflows (#13557)
  • PR-13280 - KAFKA-14735: Improve KRaft metadata image change performance at high … (#13280)
  • PR-13567 - Update zstd to 1.5.5 (#13567)
  • PR-12830 - KAFKA-8115: Reduce flakiness in Trogdor JsonRestServer shutdown (#12830)
  • PR-13534 - KAFKA-14054: Handle TimeoutException gracefully (#13534)
  • PR-13502 - KAFKA-14790: Add more AddPartitionsToTxn tests in KafkaApis and Authorizer tests (#13502)
  • PR-13536 - KAFKA-14462; [6/N] Update Records (#13536)

ksqlDB

  • PR-10198 - Set timeout to 6 hours on branches starting on 7.3.x
  • PR-10195 - Add pinned nano version for common on 7.3.x
  • PR-10196 - Add pinned nano version for common for 7.4.x
  • PR-10189 - fix: configure KsqlBoundedMemoryConfigSetter in StandaloneExecutor mode
  • PR-10175 - fix: configure KsqlBoundedMemoryConfigSetter in StandaloneExecutor mode
  • PR-10178 - fix: configure KsqlBoundedMemoryConfigSetter in StandaloneExecutor mode
  • PR-10149 - Merge Conflict Resolution (from 6.2.x to 7.0.x)
  • 722b14d9 - MINOR: fix broken build
  • PR-10109 - fix: return retryable error during shutdown
  • PR-10110 - MINOR: fix broken build
  • PR-10092 - fix: fedramp issues
  • PR-10098 - fix: vert.x regression bug when doing high volume pull query
  • PR-10103 - fix: do not continue processing records on permission errors in schema registry
  • 247e0278 - [KSQL-11372] Log pull query bandwidth rate in bytes
  • PR-10097 - fix: [KSQL-11345] fix changed TaskAssignor
  • PR-10077 - fix: concurrency bug when doing high volume pull query over java client (alternative)
  • PR-10059 - feat: FedRAMP Self-managed ksqlDB
  • PR-10065 - fix: import not picked back in fix
  • PR-10061 - fix: force the number of standby to always be zero for transient queries
  • PR-10050 - fix: checkstyle violations in KsqlConfig
  • PR-10040 - fix: delete created Kafka if the corresponding command fails
  • 193fd55f - small fixes
  • c4e7ab07 - remove logger
  • 462d924d - remove TR
  • cfa4457c - remove streams clients metrics
  • 2c849dc4 - eric comments
  • 00f2a0bf - don’t addConfluentMetricsContextConfigsKafka for streams clients
  • PR-10032 - fix: Fixes corruption in the output of pull queries with large responses
  • PR-10010 - fix: remove duplicate definition
  • PR-10006 - fix: implement default method for schema registry client
  • PR-9970 - fix: do not scan the whole classpath
  • PR-9969 - Bump io.confluent.schema-registry.version to 7.6.0-0 after bumping ksql version to 7.6

REST Proxy

  • PR-1235 - KREST-2300 Deflake KafkaConsumerManagerTest.testBackoffMsControlsPollCalls test
  • PR-1236 - KREST-NNN disable flaky test
  • PR-1230 - KREST-12372 Upgrade dependency to JDK 1.8 with version 1.77
  • PR-1221 - KREST-12630 Exclude logback from zookeeper dependency in tests
  • PR-1219 - KREST-12630 Add missing dependency due to zookeeper upgrade
  • PR-1203 - Add 413 response error for produce v3 api
  • PR-1200 - KREST-10285 example rest produce v3 streaming in javascript (nodejs)
  • PR-1196 - Create custom Properties and Map configs classes with toString method that hides password properties
  • PR-1192 - Able to drop connection if produce request is larger than a threshold
  • PR-1189 - KREST-11230 Fix tests to expect media-type application/json for errors
  • PR-1183 - Make sure that ErrorMessage is intepret as json type in response writer
  • PR-1178 - Review logging, some code tidy up
  • PR-1176 - KREST-10790 Add test for KafkaRestExceptionMapper.java
  • PR-1168 - KREST-10243 Add custom-request-logging to kafka-rest, and log error-codes for when various rate-limiters are triggered
  • PR-440 - KREST-11812 Replace EOL javaee/jaxb-api with jarkartaee/jaxb-api
  • ee8dd479 - KREST-12364: update bcpix
  • PR-420 - CIAM-2673: initialize start time in metrics before onEvent() is called
  • PR-411 - KREST-11705 Map RecordTooLargeException to KAFKA_BAD_REQUEST_ERROR_CODE
  • PR-408 - KREST-11276 - Tighten SSL auto cert reload
  • PR-409 - KREST-11276 - Fixing cert reload with multiple registered listeners
  • PR-410 - KREST-7955 421 misdirected request if host does not match SNI
  • PR-406 - Implementation of RateLimitNetworkTrafficListener
  • PR-405 - Make sure that ErrorMessage is always interpreted as json in Response
  • PR-404 - Fix typo in doc and make private property final
  • PR-402 - Add JettyRequestMetricsFilter for counting requests on Jetty layer
  • a49bb0b0 - KREST-10989: Handle ThrottlingQuotaExceededException exception as 429
  • acbc8234 - KREST-10790 Handle TopicDeletionDisabledException as 400
  • PR-398 - Introduce request attribute to enable global metrics use runtime request tags

Schema Registry

  • 0cb664f1 - Fix sharedKeys cache to account for multiple use of kms key ID
  • PR-2943 - DGS-9104: Update Bouncycastle dependencies
  • d08a0978 - fix NPE when value is nil when print.schema.ids=true is set
  • 7ec6fc8b - Fix breaking change ti ParsedSchema.validate method
  • 9408a386 - Improve err msg
  • df7effb2 - Handle alreadyExists in putKek
  • 87ca438c - Cache shared KEKs in DEK Registry
  • PR-2937 - DGS-9825: Added num_keks_shared metric
  • 13848a40 - Improve the performance of invalid name scrubbing
  • PR-2931 - Handle bug where enable.fips config is true but FIPS resource exten
  • d8edcdc7 - Add test
  • e07cbfad - DGS-9753 FIx local refs for JSON Schema 2020-12
  • 0bdb81e7 - DGS-9732 Omit decrypted DEK when registering DEK in IMPORT mode
  • 0eb5a631 - DGS-9719 Allow JSONata exprs to be used for CONDITION rules
  • 85a9e53c - DGS-9520 Also support allOf to singleton; add tests
  • 26a3423e - DGS-8901 Ensure logicalType flag passed to ReflectData
  • 414ce79f - DGS-9520 Better handling of JSON Schema singleton combined types
  • 01cc37a6 - Fix NPE for getAllVersionsById in MockSchemaRegistryClient
  • de9de139 - Handle all exceptions when rule action cannot be performed
  • 78b1947d - DGS-9450 Strip rule param prefix from configs
  • 23b859ff - DGS-9451: Fix validateFields value in error message
  • 0b445986 - DGS-9450 Add command line tool to register/auto-rotate DEKs
  • 14936914 - Refactor getAead method so it can be overridden
  • 98a1a4de - Update swagger core
  • 12166e07 - DGS-9402 In CEL, treat exception from guard as false
  • PR-2887 - DGS-9059 Fix jmx prefix default
  • 1d415181 - DGS-9387 Ensure isKey flag is passed when reusing deserializers
  • ae313e51 - Add logging
  • 6683bd00 - Fix CSFLE dek rotation tests
  • c180f450 - Fix findbugs
  • 92a148cb - Temporarily disable DEK rotation tests
  • e3deb5dd - Fix CSFLE dek rotation test
  • PR-2879 - Update azure-identity and unpin azure-core
  • bafbad8c - DGS-9343 Allow removing enum in JSON Schema to be backward compatible
  • 897e6716 - further cleanup of method calls
  • f98d9a93 - change set.of to immutableset.of in AvroSchemaTest and ProtobufSchemaTest
  • 0d57454c - Add unit tests and introduce validate fields config
  • 089b1fb7 - Upgrade tink to 1.12.0
  • 552ae00a - move reserved fields validation out of compatibility checks
  • 53982cac - DGS-9162: Metadata compatibility checks for forward and full
  • 7f7a7ab1 - add metrics-core to fix the build
  • 02a996b1 - Check multiple actions only valid for WRITEREAD and UPDOWN
  • 2f93432d - Add null check
  • 3f8d16f7 - Add initialized method to dek registry
  • cc24a287 - DGS-9106: Update log level for leader election
  • 5e7bf83d - DGS-9031 Add strings extension lib for CEL executor
  • b19aea83 - DGS-9067 Ensure keys for schema cache are not mutated
  • d3b1912d - Upgrade com.squareup.okio:okio to 3.4.0
  • a990ce0f - DGS-9031 Add builtin CEL validation functions
  • 828040f3 - DGS-7866: Set default for validateFields to false
  • 4aa97bb8 - DGS-7866: Use 35742 instead of $ as the prefix for reserved fields
  • c8ab3fd0 - Add log if encoding fails
  • PR-2832 - Rename Pre-init resource extension config
  • PR-2828 - DGS-9006: Load FIPS extension before KafkaSchemaRegistry is initialized
  • PR-2822 - Add deleted flag to create kek/dek requests
  • d81d5a53 - Encode subject names for Maven download plugin
  • PR-2820 - Cache ProtobufSchema.toDynamicSchema calls (#2818)
  • PR-2818 - Cache ProtobufSchema.toDynamicSchema calls
  • PR-2817 - Sort list of dek subjects before returning to client
  • PR-2816 - DGS-8960 Fix handling of diamond structure in Protobuf converter
  • PR-2811 - fix packaging of kafka-connect-avro-converter
  • PR-2815 - Update DEK Registry spec
  • PR-2810 - Upgrade json-skema to 0.10.0
  • PR-2807 - Allow create kek/dek to act like undelete
  • PR-2808 - For tags API, only modify ruleset on leader node
  • PR-2806 - DGS-8908 Ensure tenant prefix is used for aliases
  • PR-2805 - DGS-8901 Ensure logical type config is applied to Reflect/Specific Avro data types
  • PR-2801 - Add check and test for invalid DEK rotation expiry
  • PR-2798 - Add tests for DEK generation
  • PR-2792 - Cache missing subjects (and not just missing schemas)
  • PR-2784 - DGS-8165 Add support for automatic DEK Rotation
  • PR-2790 - DGS-8088 Get the mode in scope rather that just for the subject
  • PR-2789 - DGS-8783 Add rulesToMerge/rulesToRemove to tags API
  • PR-2786 - DGS-8769 Upgrade vault lib; add namespace support
  • PR-2781 - DGS-8542 Add support for JSON Schema Draft 2020-12
  • PR-2783 - DGS-8708 Add rule config to preserve source fields
  • PR-2782 - Add CSFLE tests for non-string fields
  • PR-2775 - Upgrade wire to 4.9.0
  • PR-2774 - Fix build due to KAFKA-9800
  • PR-2773 - DGS-8615 Minor change to DlqAction
  • PR-2771 - Checking “isCompatible” for all compatibility test responses
  • PR-2772 - DGS-8553: Updated create and delete DEK Registry API documented names
  • PR-2769 - DGS-8522 Support required fields in proto2 in CEL executor
  • PR-2765 - DGS-8334 Don’t include ts in hashCode/equals for schemas
  • PR-2764 - DGS-8336 Add ruleType filter to schemas endpoint
  • PR-2758 - DGS-8323 Always populate version metadata prop for tags API
  • PR-2762 - DGS-8320 Fix handling of primitives for JSON Schema
  • PR-2759 - DGS-8334 Add timestamp to returned schemas
  • PR-2756 - DGS-8320 Fix handling of primitives for JSON Schema
  • PR-2755 - DGS-8320 Enable defaults for JSON Schema
  • e8fa7432 - DGS-7866: Disallow properties starting with $ by default in JsonSchema
  • PR-2748 - Ensure all SR client props are passed to FLE
  • PR-2746 - Create default KMS params in rule based on KMS key id
  • PR-2745 - Log DEK errors
  • PR-2744 - MINOR Added another constructor to DekRegistryConfig
  • PR-2742 - DGS-8169 Handle null compat groups for schemas
  • b8d518d1 - DGS-7865: Add protobuf support for reserved fields and incorporate review feedback
  • PR-2741 - Improve error handling during DEK creation
  • PR-2738 - Ensure kek name is prefixed with context
  • 8cd4e320 - DGS-7865: Reserved fields support for Avro schema
  • 3018aee8 - DGS-7865: checkstyle fixes
  • e5dcee98 - DGS-7865: Reserved fields support for JSON schema
  • PR-2734 - DGS-8112 Allow properties to be omitted during serialization
  • PR-2730 - DGS-7826 DGS-7828 DGS-7830 Add kek/dek timestamp, dek version
  • PR-2682 - Fix stop service script logic
  • PR-2686 - Use static ObjectMappers
  • 9f7dad51 - Bump junit from 4.12 to 4.13.1 in /benchmark