You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by lu...@apache.org on 2026/06/29 10:13:39 UTC
(kafka) branch kip-topo updated (a3f5035c27f -> 2728e2de761)
This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a change to branch kip-topo
in repository https://gitbox.apache.org/repos/asf/kafka.git
discard a3f5035c27f KIP-1331: Fix @cluster(num_nodes=3) → num_nodes=2 in system tests
discard e4668de0d26 KIP-1331: Fix CI failures in topology description update and shard tests
discard 3c900007811 KIP-1331: Add integration tests for --topology CLI flag and Admin API topology description
discard b081209907a KIP-1331: Add integration test for group expiry without topology plugin
discard e5fd7dd28fd KIP-1331: Fix version negotiation and add integration tests for topology plugin
discard 29267cc8f77 KAFKA-20696: Periodic plugin.deleteTopology cleanup for naturally-expired streams groups
discard fc9b86e6716 KIP-1331: POC squash for rebase
add 9c7fad33973 Require expected issuer and audience for the SASL/OAUTHBEARER broker validator
add 9569137c6b9 KAFKA-20699: TopologyTestDriver.getStateStore must not reset the record context (#22590)
add d2cbb26e2b4 KAFKA-20494: Transactional InMemoryKeyValueStore (#22626)
add 89bc8808f90 KAFKA-20116: Make task-offset-sum available to client background thread (1/N) (#22595)
add 1dc4cef0bca KAFKA-20493: Transactional RocksDBStore (#22625)
add 8411977aaf9 MINOR: Move transaction coordinator leaf classes from Scala to Java (#22576)
add ec004fd80fe KAFKA-20662: Throw `INCONSISTENT_GROUP_PROTOCOL` for malformed request during online migration (#22580)
add e6919341bb8 KAFKA-20601: Allow static member rejoin when consumer group is full. (#22356)
add 16ce003d1df HOTFIX: fix compilation error (#22646)
add c12e01b9a16 MINOR: Remove jqwik dependency (#22604)
add b4da5b66e1e KAFKA-20524: Improve reset offset usability (#22607)
add 3e0787427b0 KAFKA-19871 - Add partition support to TestRecord (#22612)
add 165d7ec9334 KAFKA-19193: throw ConfigException if rack is empty in rack-aware mode (#22433)
add 88b48794eaf KAFKA-19193: trace-log rack-specific load stats in rack-aware mode (#22434)
add 076ea535fa3 KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. (#22202)
add 402087dc42e KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools (#22636)
add 9391bdd4f41 KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [1/N] (#22639)
add c9bfcf02d22 KAFKA-20719: Add integration test for sticky task assignment on startup (#22630)
add 238eb6e6a77 KAFKA-20116: Make task-end-offset-sum available to client background thread (2/N) (#22608)
add fc18c47efd6 KAFKA-19193: add Javadoc for rack-aware params in BuiltInPartitioner (#22432)
add ae1783df066 KAFKA-20686: Add base integ tests for share group DLQ. [1/N] (#22647)
add d4cd81a5ef2 KAFKA-20696: Periodic plugin.deleteTopology cleanup for naturally-expired streams groups (#22622)
add 2904f5c4928 KAFKA-18998: Move AuthHelper to server module (#22307)
add 7c2b51eea0e MINOR: Fix raw type warnings in AbstractHeartbeatRequestManagerTest (#22637)
add 28ec585cb3c KAFKA-20723: Add fail fast check for share group dlq(...). [1/N] (#22635)
add 6fd1fc703b2 MINOR: Update docker_scan supported_image_tag for 4.3.1 (#22657)
add 93d0db45199 KAFKA-20723: Merge records while coalescing share DLQ requests. [2/N] (#22662)
add 8935db691dd KAFKA-20659: Reject unsupported MirrorMaker record versions at runtime (#22504)
add d995cd14cca KAFKA-20700: Resolve symlinks in AllowedPaths before validation (#22631)
add d96cca2eb50 KAFKA-20377 Add to pass additional Docker build arguments in the system tests (#22578)
add 45b580c8a24 MINOR: Move DelayedProduceTest to server module (#22638)
add 5a91e404fa8 KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. (#22559)
add a3362c491e9 KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [2/N] (#22640)
add 6bbe144004e MINOR: Move LoggingController log level resolution test to server (#22402)
add 4fc9c58ba4a KAFKA-17840 Move ClientRequestQuotaManager to server module (#22403)
add db8f66ae36c KAFKA-20490: Replace txn buffer skip-list with TreeMap (#22648)
add bf68f79d22f KAFKA-20619: Make DetectThreadLeak ignore CleanerImpl threads (#22386)
add 1eec3d23fb9 MINOR: Fix non-idiomatic builder usage in TargetAssignmentBuilderTest (#22483)
add ca0c89d83ae MINOR: Add logging for topology description push in streams group protocol (#22670)
add eec3aad481a MINOR: Refactor downstream offset translation in OffsetSync (#22543)
add cc7e9d27de4 KAFKA-20645: Move LogLoaderTest to storage module (#22426)
add 3054383634f KAFKA-20292 [1/N]: Prepare to split TargetAssignmentBuilders (#22485)
add 81de9daf47c KAFKA-20498: Add isolation-level reads to RocksDBStore (#22653)
add 844de98644a KAFKA-20116: Send task-(end)-offset to broker (3/N) (#21803)
add 190fd8946a4 KAFKA-20553 Remove Scala dependency from streams:integration-tests (#22675)
add 82db250f504 KAFKA-18998 Clean up AuthHelper following review feedback (#22672)
add d2328ff720b KAFKA-20495: Add transactional support to in-memory window and session stores (#22652)
add e78cd1fb7c7 KAFKA-20116: Send task-(end)-offset only if changed (4/N) (#22645)
add 03910980ca5 MINOR: Code cleanups in coordinator-common runtime (#22660)
add 6c3b63b825a MINOR: Reduce allocations constructing RecordHeaders (#22641)
add 0c2c0df04a3 KAFKA-20727: Update system tests for transactional state stores (#22642)
add 980913a509a MINOR: Fix ShareGroupCommandTest reset-offsets tests passing invalid --from-file scope combination (#22679)
add cde0d5687d2 KAFKA-20743: Restrict sentinel leader and state epoch in share coord. (#22685)
add d766e485518 KAFKA-20686: Expand integration test suite for share group DLQ. [2/N] (#22671)
add 4a2edef5141 MINOR: Add 4.3.1 to system tests (#22687)
add 4861297e909 KAFKA-20292 [2/N]: Prepare to split TargetAssignmentBuilders (#22486)
add 91958dfa286 KAFKA-20169: Add ducktape test code for static membership in KIP-1071 (#22561)
add c314574ffe3 MINOR: Move BrokerReconfigurable to server module (#22409)
add 8ace44ef07f MINOR: Fix typos in documentation (#22696)
add f0ce0b4305e KIP-1331: POC squash for rebase
add ea8f6935c0d KAFKA-20696: Periodic plugin.deleteTopology cleanup for naturally-expired streams groups
add 4d8ec8d0937 KIP-1331: Fix version negotiation and add integration tests for topology plugin
add 15a439e2117 KIP-1331: Add integration test for group expiry without topology plugin
add 4db8a668703 KIP-1331: Add integration tests for --topology CLI flag and Admin API topology description
add c78b8c39b08 KIP-1331: Fix CI failures in topology description update and shard tests
add 00378fd9c00 KIP-1331: Fix @cluster(num_nodes=3) → num_nodes=2 in system tests
add 2728e2de761 KIP-1331: Fix rebase conflict artifacts left by automated resolution
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (a3f5035c27f)
\
N -- N -- N refs/heads/kip-topo (2728e2de761)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/docker_scan.yml | 2 +-
NOTICE | 4 -
NOTICE-binary | 4 -
build.gradle | 29 +-
checkstyle/import-control-group-coordinator.xml | 1 -
checkstyle/import-control-metadata.xml | 1 -
checkstyle/import-control-server-common.xml | 1 -
checkstyle/import-control-server.xml | 1 -
checkstyle/import-control-storage.xml | 1 -
checkstyle/import-control.xml | 3 +-
checkstyle/suppressions.xml | 5 +-
.../clients/consumer/ShareConsumerDLQTest.java | 620 +++++++
.../admin/AlterShareGroupOffsetsResult.java | 10 +-
.../admin/DescribeStreamsGroupsOptions.java | 5 +-
.../kafka/clients/admin/KafkaAdminClient.java | 3 +-
.../clients/admin/StreamsGroupDescription.java | 29 +-
.../admin/StreamsGroupTopologyDescription.java | 271 +--
.../StreamsGroupTopologyDescriptionStatus.java | 76 +-
.../internals/DescribeStreamsGroupsHandler.java | 119 +-
.../consumer/internals/RequestManagers.java | 6 +-
.../StreamsGroupHeartbeatRequestManager.java | 111 +-
...eamsGroupTopologyDescriptionRequestManager.java | 217 +--
.../consumer/internals/StreamsRebalanceData.java | 41 +-
.../producer/internals/BuiltInPartitioner.java | 18 +-
.../producer/internals/RecordAccumulator.java | 3 +-
.../apache/kafka/common/config/SaslConfigs.java | 34 +-
.../common/config/internals/AllowedPaths.java | 19 +-
.../config/internals/BrokerSecurityConfigs.java | 7 +-
.../common/header/internals/RecordHeaders.java | 9 +-
.../requests/StreamsGroupHeartbeatRequest.java | 5 +
.../security/oauthbearer/BrokerJwtValidator.java | 60 +-
.../kafka/clients/admin/MockAdminClientTest.java | 132 ++
.../DescribeStreamsGroupsHandlerTest.java | 364 ++--
.../AbstractHeartbeatRequestManagerTest.java | 16 +-
.../consumer/internals/AsyncKafkaConsumerTest.java | 10 +-
.../ConsumerHeartbeatRequestManagerTest.java | 6 +-
.../consumer/internals/RequestManagersTest.java | 10 +-
.../ShareHeartbeatRequestManagerTest.java | 6 +-
.../StreamsGroupHeartbeatRequestManagerTest.java | 695 +++++++-
...GroupTopologyDescriptionRequestManagerTest.java | 405 +++--
.../internals/StreamsMembershipManagerTest.java | 125 +-
.../internals/StreamsRebalanceDataTest.java | 84 +-
.../events/ApplicationEventProcessorTest.java | 4 +-
.../common/config/provider/AllowedPathsTest.java | 26 +-
.../requests/StreamsGroupHeartbeatRequestTest.java | 65 +
.../oauthbearer/BrokerJwtValidatorTest.java | 212 ++-
.../oauthbearer/DefaultJwtValidatorTest.java | 66 +-
.../OAuthBearerValidatorCallbackHandlerTest.java | 36 +-
.../kafka/clients/admin/MockAdminClient.java | 41 +-
.../apache/kafka/connect/mirror/Checkpoint.java | 5 +-
.../org/apache/kafka/connect/mirror/Heartbeat.java | 5 +-
.../connect/mirror/MirrorRecordVersionTest.java | 88 +
.../apache/kafka/connect/mirror/OffsetSync.java | 8 +
.../kafka/connect/mirror/OffsetSyncStore.java | 6 +-
.../kafka/connect/mirror/OffsetSyncWriter.java | 5 +-
.../common/runtime/CoordinatorLoaderImpl.java | 2 +-
.../common/runtime/CoordinatorRuntime.java | 6 +-
.../runtime/CoordinatorRuntimeMetricsImpl.java | 4 +-
.../common/runtime/CoordinatorLoaderImplTest.java | 41 +-
.../common/runtime/EventAccumulatorTest.java | 2 +-
.../runtime/MultiThreadedEventProcessorTest.java | 9 +-
.../common/runtime/MetadataImageBuilder.java | 4 +-
core/src/main/java/kafka/server/QuotaFactory.java | 1 +
.../DescribeTopicPartitionsRequestHandler.java | 2 +-
.../transaction/TransactionCoordinator.scala | 10 +-
.../TransactionMarkerChannelManager.scala | 83 +-
...TransactionMarkerRequestCompletionHandler.scala | 1 +
core/src/main/scala/kafka/server/AclApis.scala | 1 +
core/src/main/scala/kafka/server/AuthHelper.scala | 176 --
.../src/main/scala/kafka/server/BrokerServer.scala | 7 +
.../src/main/scala/kafka/server/ConfigHelper.scala | 1 +
.../main/scala/kafka/server/ControllerApis.scala | 44 +-
.../scala/kafka/server/DynamicBrokerConfig.scala | 7 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 119 +-
.../server/metadata/BrokerMetadataPublisher.scala | 5 +-
.../DescribeTopicPartitionsRequestHandlerTest.java | 6 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 3 +-
.../kafka/api/ClientOAuthIntegrationTest.scala | 1 +
.../kafka/api/IntegrationTestHarness.scala | 3 +-
core/src/test/scala/kafka/utils/LoggingTest.scala | 20 -
.../TransactionCoordinatorConcurrencyTest.scala | 2 +-
.../transaction/TransactionCoordinatorTest.scala | 70 +-
...sactionMarkerRequestCompletionHandlerTest.scala | 6 +-
.../test/scala/unit/kafka/log/LogLoaderTest.scala | 1647 -----------------
.../test/scala/unit/kafka/log/LogTestUtils.scala | 311 ----
.../scala/unit/kafka/server/AuthHelperTest.scala | 261 ---
.../kafka/server/BaseClientQuotaManagerTest.scala | 84 -
.../unit/kafka/server/ClientQuotaManagerTest.scala | 626 -------
.../server/ClientRequestQuotaManagerTest.scala | 99 --
.../unit/kafka/server/ControllerApisTest.scala | 40 +-
.../ControllerMutationQuotaManagerTest.scala | 243 ---
.../unit/kafka/server/DelayedProduceTest.scala | 83 -
.../scala/unit/kafka/server/KafkaApisTest.scala | 10 +-
docs/getting-started/upgrade.md | 2 +
docs/operations/basic-kafka-operations.md | 25 +-
docs/streams/developer-guide/config-streams.md | 2 +-
.../developer-guide/kafka-streams-group-sh.md | 7 +-
docs/streams/developer-guide/memory-mgmt.md | 2 +-
.../developer-guide/streams-rebalance-protocol.md | 4 +-
docs/streams/developer-guide/testing.md | 2 +-
docs/streams/upgrade-guide.md | 6 +-
gradle/dependencies.gradle | 4 +-
gradle/spotbugs-exclude.xml | 7 +
.../coordinator/group/GroupCoordinatorService.java | 158 +-
.../coordinator/group/GroupCoordinatorShard.java | 138 +-
.../coordinator/group/GroupMetadataManager.java | 32 +-
.../coordinator/group/OffsetMetadataManager.java | 84 +-
.../group/metrics/GroupCoordinatorMetrics.java | 110 +-
.../coordinator/group/streams/StreamsGroup.java | 12 +
.../StreamsGroupTopologyDescriptionManager.java | 147 +-
.../kafka/coordinator/group/util/OverlayMap.java | 193 ++
.../UpdatedMembersAndTargetAssignmentView.java | 123 ++
.../group/GroupCoordinatorServiceTest.java | 34 -
...pCoordinatorServiceTopologyDescriptionTest.java | 288 +++
.../group/GroupCoordinatorShardTest.java | 74 +-
.../group/GroupMetadataManagerTest.java | 241 ++-
.../group/OffsetMetadataManagerTest.java | 45 +-
.../group/streams/TargetAssignmentBuilderTest.java | 5 +-
.../coordinator/group/util/OverlayMapTest.java | 359 ++++
.../UpdatedMembersAndTargetAssignmentViewTest.java | 191 ++
.../metadata/KRaftMetadataRequestBenchmark.java | 2 +-
.../kafka/metadata/PartitionRegistrationTest.java | 36 +-
.../authorizer/StandardAuthorizerPropertyTest.java | 267 +--
.../kafka/raft/KafkaRaftClientFetchTest.java | 15 +-
.../java/org/apache/kafka/raft/MockLogTest.java | 28 +-
.../apache/kafka/raft/RaftEventSimulationTest.java | 642 +++----
.../kafka/raft/internals/KafkaRaftLogTest.java | 39 +-
.../kafka/raft/internals/RecordsIteratorTest.java | 117 +-
.../record/internal/ArbitraryMemoryRecords.java | 31 +-
.../java/org/apache/kafka/server/AuthHelper.java | 267 +++
.../kafka/server}/config/BrokerReconfigurable.java | 12 +-
.../server/config/DynamicLogCleanerConfig.java | 30 +-
.../config/DynamicProducerStateManagerConfig.java | 6 +-
.../server/quota}/ClientRequestQuotaManager.java | 6 +-
.../share/dlq/DefaultShareGroupDLQManager.java | 16 +-
.../share/dlq/ShareGroupDLQStateManager.java | 60 +-
.../org/apache/kafka/server/AuthHelperTest.java | 325 ++++
.../kafka/server/logger/LoggingControllerTest.java | 46 +
.../kafka/server/purgatory/DelayedProduceTest.java | 261 +++
.../server/quota/BaseClientQuotaManagerTest.java | 97 +
.../kafka/server/quota/ClientQuotaManagerTest.java | 620 +++++++
.../quota/ClientRequestQuotaManagerTest.java | 104 ++
.../quota/ControllerMutationQuotaManagerTest.java | 243 +++
.../share/dlq/ShareGroupDLQStateManagerTest.java | 125 +-
.../coordinator/share/ShareCoordinatorShard.java | 43 +-
.../share/ShareCoordinatorShardTest.java | 123 +-
.../kafka/storage/internals/log/LogCleaner.java | 22 +-
.../internals/log/LogCleanerIntegrationTest.java | 18 +-
.../storage/internals/log/LogCleanerTest.java | 14 +-
.../kafka/storage/internals/log/LogLoaderTest.java | 1863 ++++++++++++++++++++
.../kafka/storage/internals/log/LogTestUtils.java | 73 +-
.../ColdStartStickinessIntegrationTest.java | 266 +++
.../KafkaStreamsCloseOptionsIntegrationTest.java | 71 +-
.../KafkaStreamsStaticMemberIntegrationTest.java | 596 +++++++
...bleJoinScalaIntegrationTestImplicitSerdes.scala | 175 --
.../kafka/streams/integration/WordCountTest.scala | 250 ---
...StreamToTableJoinScalaIntegrationTestBase.scala | 144 --
.../utils/StreamToTableJoinTestData.scala | 60 -
.../org/apache/kafka/streams/StreamsConfig.java | 21 +-
.../ApplicationServerConfigValidator.java | 27 +-
.../processor/internals/ChangelogReader.java | 5 +
.../processor/internals/DefaultStateUpdater.java | 49 +
.../internals/InternalTopologyBuilder.java | 12 +
.../processor/internals/StateDirectory.java | 4 +
.../streams/processor/internals/StateUpdater.java | 8 +
.../processor/internals/StoreChangelogReader.java | 17 +
.../streams/processor/internals/StreamThread.java | 53 +-
.../streams/processor/internals/TaskManager.java | 52 +
.../internals/TopologyDescriptionConverter.java | 109 ++
.../org/apache/kafka/streams/state/HostInfo.java | 15 +-
.../internals/AbstractColumnFamilyAccessor.java | 5 +
.../state/internals/AbstractTransactionBuffer.java | 85 +-
.../state/internals/DualColumnFamilyAccessor.java | 5 +
.../state/internals/InMemoryKeyValueStore.java | 61 +-
.../state/internals/InMemorySessionStore.java | 262 ++-
.../InMemorySessionTransactionBuffer.java | 278 +++
.../state/internals/InMemoryTransactionBuffer.java | 174 ++
.../state/internals/InMemoryWindowStore.java | 405 ++++-
.../internals/InMemoryWindowTransactionBuffer.java | 203 +++
.../streams/state/internals/RocksDBStore.java | 252 +++
.../state/internals/RocksDBTransactionBuffer.java | 375 ++++
.../apache/kafka/streams/StreamsConfigTest.java | 53 +-
.../internals/DefaultStateUpdaterTest.java | 90 +
.../DefaultStreamsRebalanceListenerTest.java | 18 +-
.../processor/internals/MockChangelogReader.java | 5 +
.../internals/StoreChangelogReaderTest.java | 27 +
.../processor/internals/StreamThreadTest.java | 120 +-
.../processor/internals/TaskManagerTest.java | 39 +
.../TopologyDescriptionConverterTest.java | 366 ++++
.../apache/kafka/streams/state/HostInfoTest.java | 8 +
.../internals/AbstractSessionBytesStoreTest.java | 12 +-
.../internals/AbstractTransactionBufferTest.java | 106 ++
.../internals/AbstractWindowBytesStoreTest.java | 14 +-
.../DualColumnFamilyAccessorTransactionalTest.java | 318 ++++
.../internals/InMemoryTransactionBufferTest.java | 226 +++
.../InMemoryTransactionalSessionStoreTest.java | 77 +
.../InMemoryTransactionalWindowStoreTest.java | 125 ++
.../streams/state/internals/RocksDBStoreTest.java | 185 ++
.../internals/RocksDBTimestampedStoreTest.java | 58 +
.../internals/RocksDBTransactionBufferTest.java | 481 +++++
.../streams/tests/StaticMemberTestClient.java | 13 +
.../streams/scala/StreamToTableJoinTest.scala | 106 ++
.../apache/kafka/streams/TopologyTestDriver.java | 7 +-
.../org/apache/kafka/streams/test/TestRecord.java | 144 +-
.../kafka/streams/TopologyTestDriverTest.java | 60 +
.../apache/kafka/streams/test/TestRecordTest.java | 128 +-
.../common/test/junit/ClusterTestExtensions.java | 8 +-
tests/docker/Dockerfile | 4 +-
tests/docker/ducker-ak | 10 +-
tests/kafkatest/services/streams.py | 19 +-
.../kafkatest/tests/streams/streams_smoke_test.py | 15 +-
.../streams/streams_static_membership_test.py | 407 ++++-
tests/kafkatest/version.py | 3 +-
.../group/ConsumerGroupCommandOptions.java | 56 +-
.../tools/consumer/group/ShareGroupCommand.java | 2 +-
.../consumer/group/ShareGroupCommandOptions.java | 44 +-
.../kafka/tools/streams/StreamsGroupCommand.java | 44 +-
.../tools/streams/StreamsGroupCommandOptions.java | 46 +-
.../streams/TopologyDescriptionFormatter.java | 104 +-
.../consumer/group/ShareGroupCommandTest.java | 6 +-
.../tools/streams/StreamsGroupCommandTest.java | 61 +
.../streams/TopologyDescriptionFormatterTest.java | 182 +-
...dTxnMetadata.java => InitProducerIdResult.java} | 4 +-
...AndTxnMetadata.java => PendingCompleteTxn.java} | 7 +-
....java => PendingCompleteTxnAndMarkerEntry.java} | 7 +-
.../coordinator/transaction/TxnMarkerQueue.java | 100 ++
vagrant/base.sh | 4 +-
227 files changed, 17211 insertions(+), 6768 deletions(-)
create mode 100644 clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerDLQTest.java
create mode 100644 clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClientTest.java
create mode 100644 clients/src/test/java/org/apache/kafka/common/requests/StreamsGroupHeartbeatRequestTest.java
create mode 100644 connect/mirror-client/src/test/java/org/apache/kafka/connect/mirror/MirrorRecordVersionTest.java
delete mode 100644 core/src/main/scala/kafka/server/AuthHelper.scala
delete mode 100644 core/src/test/scala/unit/kafka/log/LogLoaderTest.scala
delete mode 100644 core/src/test/scala/unit/kafka/log/LogTestUtils.scala
delete mode 100644 core/src/test/scala/unit/kafka/server/AuthHelperTest.scala
delete mode 100644 core/src/test/scala/unit/kafka/server/BaseClientQuotaManagerTest.scala
delete mode 100644 core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala
delete mode 100644 core/src/test/scala/unit/kafka/server/ClientRequestQuotaManagerTest.scala
delete mode 100644 core/src/test/scala/unit/kafka/server/ControllerMutationQuotaManagerTest.scala
delete mode 100644 core/src/test/scala/unit/kafka/server/DelayedProduceTest.scala
create mode 100644 group-coordinator/src/main/java/org/apache/kafka/coordinator/group/util/OverlayMap.java
create mode 100644 group-coordinator/src/main/java/org/apache/kafka/coordinator/group/util/UpdatedMembersAndTargetAssignmentView.java
create mode 100644 group-coordinator/src/test/java/org/apache/kafka/coordinator/group/util/OverlayMapTest.java
create mode 100644 group-coordinator/src/test/java/org/apache/kafka/coordinator/group/util/UpdatedMembersAndTargetAssignmentViewTest.java
create mode 100644 server/src/main/java/org/apache/kafka/server/AuthHelper.java
rename {server-common/src/main/java/org/apache/kafka => server/src/main/java/org/apache/kafka/server}/config/BrokerReconfigurable.java (87%)
copy clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenMock.java => server/src/main/java/org/apache/kafka/server/config/DynamicLogCleanerConfig.java (51%)
rename {core/src/main/java/kafka/server => server/src/main/java/org/apache/kafka/server/quota}/ClientRequestQuotaManager.java (95%)
create mode 100644 server/src/test/java/org/apache/kafka/server/AuthHelperTest.java
create mode 100644 server/src/test/java/org/apache/kafka/server/logger/LoggingControllerTest.java
create mode 100644 server/src/test/java/org/apache/kafka/server/purgatory/DelayedProduceTest.java
create mode 100644 server/src/test/java/org/apache/kafka/server/quota/BaseClientQuotaManagerTest.java
create mode 100644 server/src/test/java/org/apache/kafka/server/quota/ClientQuotaManagerTest.java
create mode 100644 server/src/test/java/org/apache/kafka/server/quota/ClientRequestQuotaManagerTest.java
create mode 100644 server/src/test/java/org/apache/kafka/server/quota/ControllerMutationQuotaManagerTest.java
create mode 100644 storage/src/test/java/org/apache/kafka/storage/internals/log/LogLoaderTest.java
create mode 100644 streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ColdStartStickinessIntegrationTest.java
create mode 100644 streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsStaticMemberIntegrationTest.java
delete mode 100644 streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala
delete mode 100644 streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/WordCountTest.scala
delete mode 100644 streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/utils/StreamToTableJoinScalaIntegrationTestBase.scala
delete mode 100644 streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/utils/StreamToTableJoinTestData.scala
copy connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/RegexValidator.java => streams/src/main/java/org/apache/kafka/streams/internals/ApplicationServerConfigValidator.java (56%)
create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyDescriptionConverter.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionTransactionBuffer.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTransactionBuffer.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowTransactionBuffer.java
create mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTransactionBuffer.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/TopologyDescriptionConverterTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/DualColumnFamilyAccessorTransactionalTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryTransactionBufferTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryTransactionalSessionStoreTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/InMemoryTransactionalWindowStoreTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTransactionBufferTest.java
create mode 100644 streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinTest.scala
copy transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/{CoordinatorEpochAndTxnMetadata.java => InitProducerIdResult.java} (86%)
copy transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/{CoordinatorEpochAndTxnMetadata.java => PendingCompleteTxn.java} (83%)
copy transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/{CoordinatorEpochAndTxnMetadata.java => PendingCompleteTxnAndMarkerEntry.java} (80%)
create mode 100644 transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/TxnMarkerQueue.java