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
