This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch KAFKA-15183
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 14957958940 fix checkstyle
new d3aaeae757d Make sure sizeInBytes can be called after freeze in every
case. fix test
add fa5b493241d KAFKA-14647: Move TopicFilter to server-common/utils
(#13158)
add 0c6b1a4e9a9 KAFKA-14737: Move kafka.utils.json to server-common
(#13585)
add a1f6ab69387 MINOR: Update .asf.yaml file with refreshed
github_whitelist, and collaborators
add 3580f453810 Revert "MINOR: Update .asf.yaml file with refreshed
github_whitelist, and collaborators" (#14037)
add 0b025b77113 KAFKA-15121: Implement the alterOffsets method in the
FileStreamSourceConnector and the FileStreamSinkConnector (#13945)
add fd3b1137d2f KAFKA-14953: Add tiered storage related metrics (#13944)
add 5cb2504c493 KAFKA-14669: Use the generated docs for MirrorMaker
configs in the doc (#13658)
add d6aaddf6ee3 KAFKA-15091: Fix misleading Javadoc for SourceTask::commit
(#13948)
add a82df3000a4 MINOR: Update docs to include ZK deprecation notice and
information (#14031)
add a500c3ecf9a KAFKA-14500; [5/N] Implement JoinGroup protocol in new
GroupCoordinator (#13870)
add f66a0f0babf KAFKA-15199: Remove Leading and Trailing Spaces in
release.py (#14035)
add 2999168cde3 MINOR: Upgrade Gradle wrapper version to 8.2.1 (#14032)
add 1f7f6ceebf5 KAFKA-15211: Mock InvalidParameterException in
DistributedConfigTest (#14039)
add a68281bf3c7 MINOR: Fix Connect compatibility javadocs to use
NoSuchMethodError instead of NoSuchMethodException (#14036)
add 29f36d733b4 KAFKA-15141: Initialize logger statically on hot codepaths
(#13949)
add d5a00cca74d KAFKA-15162: Reflectively find plugins in parent
ClassLoaders that aren't on the classpath (#13977)
add 844469311aa KAFKA-10579: Upgrade reflections from 0.9.12 to 0.10.2
(#14029)
add f6e7aa37633 KAFKA-15150: Add ServiceLoaderScanner implementation
(#13971)
add 583f7080066 MINOR: Delete unneeded classgraph-MIT license (#14040)
add 334c41d6042 KAFKA-14734: Use CommandDefaultOptions in StreamsResetter
(#13983)
add e9fe2a2eeaf KAFKA-14936: Check the versioned table's history retention
and compare to grace period (4/N) (#13942)
add ea6e100ec31 KAFKA-15216: InternalSinkRecord::newRecord should not
ignore new headers (#14044)
add 01a16ca301d KAFKA-14469: Add MirrorMaker configs to table of contents
in docs page (#14041)
add 8f313eaed4f KAFKA-14133: Migrate various mocks in TaskManagerTest to
Mockito (#13874)
add 125dbb92867 KAFKA-14760: Move ThroughputThrottler from tools to
clients, remove tools dependency from connect-runtime (#13313)
add 6bb88ae2f74 KAFKA-15022: [2/N] introduce graph to compute min cost
(#13996)
add 27ea025e33a KAFKA-15176: add tests for tiered storage metrics (#13999)
add 4ea9394e7eb MINOR Fix the build failure (#14065)
add e9fc7429798 KAFKA-15222: upgrade zinc scala plugin to 1.9.2 (#14060)
add 2e30dd894f4 MINOR: add JDK 20 build support to README (#14061)
add 4bba2c8a32a KAFKA-14591: Move DeleteRecordsCommand to tools (#13278)
add 4daeb2714c2 KAFKA-13431 (KIP-793): Expose the original pre-transform
topic partition and offset in sink records (#14024)
add 69659b70fca KAFKA-14499: [1/N] Introduce OffsetCommit API version 9
and add new StaleMemberEpochException error (#14046)
add 2528dd41169 KAFKA-14499: [2/N] Add OffsetCommit record & related
(#14047)
add 1bf73d89d0d KAFKA-15232: Move ToolsUtils to tools (#14066)
add 1656591d0b3 KAFKA-14950: implement assign() and assignment() (#13797)
add cc4e699d4cb MINOR: Minor logging and doc related improvements in
topic-based RLMM consumer-manager/task (#14045)
add a3204aed2eb KAFKA-15194: Prepend offset in the filenames used by
LocalTieredStorage (#14057)
add 4981fa939d5 KAFKA-14712: Produce correct error msg with correct
metadataversion (#13773)
add 84691b11f64 KAFKA-15168: Handle overlapping remote log segments in
RemoteLogMetadata cache (#14004)
add 38781f9aea2 KAFKA-14920: Address timeouts and out of order sequences
(#14033)
add 79b8c969e53 KAFKA-14990: Dynamic producer ID expiration should be
applied on a broker restart (#13707)
new df7b7bde40d Merge branch 'trunk' into KAFKA-15183
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
LICENSE-binary | 3 +-
README.md | 2 +-
bin/kafka-delete-records.sh | 2 +-
bin/windows/kafka-delete-records.bat | 2 +-
build.gradle | 13 +-
checkstyle/import-control-core.xml | 1 +
checkstyle/import-control-server-common.xml | 3 +
checkstyle/import-control.xml | 9 +-
checkstyle/suppressions.xml | 14 +-
.../consumer/internals/CommitRequestManager.java | 9 +-
.../consumer/internals/ConsumerCoordinator.java | 2 +-
.../internals/DefaultBackgroundThread.java | 24 +-
.../consumer/internals/DefaultEventHandler.java | 3 +
.../consumer/internals/PrototypeAsyncConsumer.java | 33 +-
.../internals/events/ApplicationEvent.java | 2 +-
.../events/ApplicationEventProcessor.java | 30 +-
....java => AssignmentChangeApplicationEvent.java} | 30 +-
.../NewTopicsMetadataUpdateRequestEvent.java | 15 +-
.../errors/StaleMemberEpochException.java} | 31 +-
.../org/apache/kafka/common/protocol/Errors.java | 4 +-
.../kafka/common/requests/AbstractRequest.java | 9 +-
.../requests/ConsumerGroupHeartbeatRequest.java | 6 +-
.../kafka/common/requests/JoinGroupRequest.java | 62 +
.../kafka/common/requests/OffsetCommitRequest.java | 49 +-
.../kafka/common/utils}/ThroughputThrottler.java | 2 +-
.../common/message/OffsetCommitRequest.json | 12 +-
.../common/message/OffsetCommitResponse.json | 15 +-
.../internals/CommitRequestManagerTest.java | 2 +-
.../internals/ConsumerCoordinatorTest.java | 2 +-
.../internals/DefaultBackgroundThreadTest.java | 93 +-
.../internals/PrototypeAsyncConsumerTest.java | 43 +-
.../apache/kafka/common/message/MessageTest.java | 4 +-
.../common/requests/OffsetCommitRequestTest.java | 42 +-
.../kafka/common/requests/RequestResponseTest.java | 2 +-
.../org/apache/kafka/connect/sink/SinkRecord.java | 144 +-
.../org/apache/kafka/connect/sink/SinkTask.java | 37 +-
.../apache/kafka/connect/sink/SinkTaskContext.java | 2 +-
.../apache/kafka/connect/source/SourceTask.java | 7 +-
.../kafka/connect/source/SourceTaskContext.java | 2 +-
.../apache/kafka/connect/sink/SinkRecordTest.java | 36 +-
.../connect/file/FileStreamSinkConnector.java | 8 +
.../connect/file/FileStreamSourceConnector.java | 49 +
.../file/FileStreamSourceConnectorTest.java | 88 +-
.../connect/mirror/MirrorCheckpointConfig.java | 178 +-
.../connect/mirror/MirrorConnectorConfig.java | 4 +
.../connect/mirror/MirrorHeartbeatConfig.java | 14 +-
.../kafka/connect/mirror/MirrorSourceConfig.java | 256 +-
.../kafka/connect/runtime/InternalSinkRecord.java | 11 +-
.../connect/runtime/isolation/PluginScanner.java | 70 +-
.../connect/runtime/isolation/PluginSource.java | 4 +-
.../connect/runtime/isolation/PluginUtils.java | 6 +-
.../runtime/isolation/ReflectionScanner.java | 85 +-
.../runtime/isolation/ServiceLoaderScanner.java | 80 +
.../kafka/connect/tools/SchemaSourceTask.java | 2 +-
.../kafka/connect/tools/VerifiableSourceTask.java | 2 +-
.../integration/MonitorableSourceConnector.java | 2 +-
.../connect/runtime/InternalSinkRecordTest.java | 61 +
.../kafka/connect/runtime/WorkerSinkTaskTest.java | 43 +-
.../runtime/WorkerSinkTaskThreadedTest.java | 2 +-
.../runtime/distributed/DistributedConfigTest.java | 11 +-
.../runtime/isolation/PluginScannerTest.java | 97 +-
.../connect/runtime/isolation/PluginsTest.java | 7 +-
.../connect/runtime/isolation/TestPlugins.java | 2 +-
.../org.apache.kafka.connect.storage.Converter | 16 +
.../org.apache.kafka.connect.storage.Converter | 16 +
.../org.apache.kafka.connect.sink.SinkConnector | 21 +
.../org.apache.kafka.connect.storage.Converter | 19 +
.../org.apache.kafka.connect.storage.Converter | 17 +
.../org.apache.kafka.connect.storage.Converter | 16 +
.../test/plugins/ReadVersionFromResource.java | 12 +-
.../org.apache.kafka.connect.storage.Converter | 16 +
.../test/plugins/ReadVersionFromResource.java | 12 +-
.../org.apache.kafka.connect.storage.Converter | 16 +
.../org.apache.kafka.connect.sink.SinkConnector | 16 +
.../org.apache.kafka.connect.storage.Converter | 16 +
...rg.apache.kafka.connect.storage.HeaderConverter | 16 +
.../org.apache.kafka.connect.storage.Converter | 16 +
.../org.apache.kafka.connect.storage.Converter | 16 +
.../java/kafka/log/remote/RemoteLogManager.java | 51 +-
.../java/kafka/log/remote/RemoteLogReader.java | 12 +-
core/src/main/scala/kafka/admin/AdminUtils.scala | 2 +-
.../scala/kafka/admin/DeleteRecordsCommand.scala | 137 -
.../scala/kafka/admin/LeaderElectionCommand.scala | 2 +-
.../kafka/admin/ReassignPartitionsCommand.scala | 2 +-
core/src/main/scala/kafka/admin/TopicCommand.scala | 5 +-
core/src/main/scala/kafka/cluster/Partition.scala | 4 +-
.../scala/kafka/controller/KafkaController.scala | 3 +-
.../group/GroupCoordinatorAdapter.scala | 2 +-
core/src/main/scala/kafka/log/UnifiedLog.scala | 24 +-
.../src/main/scala/kafka/server/BrokerServer.scala | 9 +-
.../main/scala/kafka/server/DelayedProduce.scala | 9 +-
.../src/main/scala/kafka/server/FetchSession.scala | 21 +
core/src/main/scala/kafka/server/KafkaApis.scala | 2 +-
core/src/main/scala/kafka/server/KafkaConfig.scala | 14 +-
.../scala/kafka/server/KafkaRequestHandler.scala | 30 +
core/src/main/scala/kafka/server/KafkaServer.scala | 2 +-
.../main/scala/kafka/server/ReplicaManager.scala | 3 +-
.../main/scala/kafka/server/ZkAdminManager.scala | 3 +-
.../main/scala/kafka/tools/ConsoleConsumer.scala | 1 -
.../main/scala/kafka/tools/GetOffsetShell.scala | 91 +-
core/src/main/scala/kafka/tools/MirrorMaker.scala | 4 +-
.../kafka/tools/ReplicaVerificationTool.scala | 3 +-
core/src/main/scala/kafka/utils/TopicFilter.scala | 55 -
core/src/main/scala/kafka/zk/AdminZkClient.scala | 3 +-
.../kafka/log/remote/RemoteLogManagerTest.java | 238 +-
.../java/kafka/log/remote/RemoteLogReaderTest.java | 40 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 3 +-
.../kafka/api/ProducerIdExpirationTest.scala | 6 +-
.../kafka/server/KRaftClusterTest.scala | 2 +-
.../scala/unit/kafka/admin/AddPartitionsTest.scala | 1 +
.../admin/LeaderElectionCommandErrorTest.scala | 2 +-
.../kafka/admin/LeaderElectionCommandTest.scala | 3 +-
.../kafka/admin/ReassignPartitionsUnitTest.scala | 2 +-
.../scala/unit/kafka/admin/TopicCommandTest.scala | 2 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 8 +-
.../group/GroupCoordinatorAdapterTest.scala | 4 +-
.../unit/kafka/log/ProducerStateManagerTest.scala | 57 +-
.../test/scala/unit/kafka/log/UnifiedLogTest.scala | 37 +-
.../server/ConsumerGroupHeartbeatRequestTest.scala | 15 +-
.../unit/kafka/server/DynamicConfigTest.scala | 2 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 10 +-
.../unit/kafka/server/ReplicaManagerTest.scala | 339 ++-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 4 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 14 +-
.../scala/unit/kafka/utils/TopicFilterTest.scala | 49 -
.../scala/unit/kafka/zk/AdminZkClientTest.scala | 1 +
docs/configuration.html | 47 +-
docs/ops.html | 38 +-
docs/toc.html | 3 +-
gradle/dependencies.gradle | 6 +-
gradle/wrapper/gradle-wrapper.properties | 4 +-
gradlew | 2 +-
.../coordinator/group/GroupCoordinatorConfig.java | 42 +-
.../coordinator/group/GroupCoordinatorService.java | 40 +-
.../coordinator/group/GroupMetadataManager.java | 1504 ++++++++++-
.../kafka/coordinator/group/OffsetAndMetadata.java | 125 +
.../kafka/coordinator/group/RecordHelpers.java | 100 +
.../group/ReplicatedGroupCoordinator.java | 46 +-
.../coordinator/group/generic/GenericGroup.java | 111 +-
.../group/generic/GenericGroupMember.java | 104 +-
.../kafka/coordinator/group/generic/Protocol.java | 87 -
.../group/runtime/CoordinatorBuilder.java | 14 +-
.../group/runtime/CoordinatorResult.java | 70 +-
.../group/runtime/CoordinatorRuntime.java | 17 +-
.../group/runtime/CoordinatorTimer.java | 9 +-
.../common/message/GroupMetadataValue.json | 2 +-
.../group/GroupCoordinatorConfigTest.java | 12 +-
.../group/GroupCoordinatorServiceTest.java | 129 +-
.../group/GroupMetadataManagerTest.java | 2641 ++++++++++++++++++--
.../coordinator/group/MockCoordinatorTimer.java | 45 +-
.../coordinator/group/OffsetAndMetadataTest.java | 74 +
.../kafka/coordinator/group/RecordHelpersTest.java | 188 +-
.../group/ReplicatedGroupCoordinatorTest.java | 37 +
.../group/generic/GenericGroupMemberTest.java | 127 +-
.../group/generic/GenericGroupTest.java | 328 +--
.../group/runtime/CoordinatorRuntimeTest.java | 40 +-
.../apache/kafka/jmh/server/CheckpointBench.java | 2 +-
licenses/classgraph-MIT | 21 -
.../kafka/image/writer/ImageWriterOptions.java | 19 +-
.../org/apache/kafka/image/ImageDowngradeTest.java | 2 +-
.../kafka/image/writer/ImageWriterOptionsTest.java | 21 +
.../kafka/snapshot/FileRawSnapshotWriter.java | 14 +-
.../kafka/raft/KafkaRaftClientSnapshotTest.java | 22 +-
.../kafka/snapshot/MockRawSnapshotWriter.java | 2 +-
release.py | 24 +-
.../server/common/AdminCommandFailedException.java | 19 +-
.../server/common/AdminOperationException.java | 21 +-
.../kafka/server/common/MetadataVersion.java | 12 +
.../java/org/apache/kafka/server/util/Json.java | 107 +
.../apache/kafka/server/util/PartitionFilter.java | 66 +
.../org/apache/kafka/server/util/TopicFilter.java | 73 +
.../kafka/server/util/TopicPartitionFilter.java | 71 +
.../apache/kafka/server/util/json/DecodeJson.java | 127 +
.../apache/kafka/server/util/json/JsonArray.java | 67 +
.../apache/kafka/server/util/json/JsonObject.java | 82 +
.../apache/kafka/server/util/json/JsonValue.java | 130 +
.../kafka/server/common/MetadataVersionTest.java | 20 +
.../org/apache/kafka/server/util/JsonTest.java | 233 ++
.../apache/kafka/server/util/TopicFilterTest.java | 51 +
.../remote/metadata/storage/ConsumerManager.java | 33 +-
.../log/remote/metadata/storage/ConsumerTask.java | 15 +-
.../storage/RemoteLogLeaderEpochState.java | 24 +-
.../TopicBasedRemoteLogMetadataManager.java | 36 +-
.../TopicBasedRemoteLogMetadataManagerConfig.java | 8 +
.../kafka/storage/internals/log/LogFileUtils.java | 2 +-
.../storage/internals/log/ProducerAppendInfo.java | 31 +-
.../internals/log/ProducerStateManager.java | 26 +-
.../internals/log/RemoteStorageThreadPool.java | 32 +-
.../internals/log/VerificationStateEntry.java | 42 +-
.../storage/RemoteLogLeaderEpochStateTest.java | 206 ++
.../storage/RemoteLogSegmentLifecycleTest.java | 8 +-
...picBasedRemoteLogMetadataManagerConfigTest.java | 13 +-
...icBasedRemoteLogMetadataManagerRestartTest.java | 2 +-
.../TopicBasedRemoteLogMetadataManagerTest.java | 8 +-
.../log/remote/storage/LocalTieredStorage.java | 34 +-
.../log/remote/storage/LocalTieredStorageTest.java | 77 +-
.../remote/storage/RemoteLogSegmentFileset.java | 34 +-
.../streams/kstream/internals/KStreamImpl.java | 5 +-
.../internals/graph/StreamTableJoinNode.java | 17 +-
.../internals/InternalTopologyBuilder.java | 9 +
.../processor/internals/assignment/Graph.java | 377 +++
.../{ => assignment}/RackAwareTaskAssignor.java | 3 +-
.../integration/AbstractResetIntegrationTest.java | 2 +-
.../streams/integration/ResetIntegrationTest.java | 10 +-
.../kstream/internals/KStreamKTableJoinTest.java | 70 +
.../processor/internals/TaskManagerTest.java | 97 +-
.../processor/internals/assignment/GraphTest.java | 414 +++
.../assignment/RackAwareTaskAssignorTest.java | 1 -
tests/kafkatest/directory_layout/kafka_path.py | 7 +-
.../sanity_checks/test_verifiable_producer.py | 2 +-
tests/kafkatest/services/verifiable_client.py | 9 +-
.../apache/kafka/tools/ConsumerPerformance.java | 1 -
.../apache/kafka/tools/DeleteRecordsCommand.java | 183 ++
.../apache/kafka/tools/MetadataQuorumCommand.java | 1 -
.../apache/kafka/tools/ProducerPerformance.java | 2 +-
.../org/apache/kafka/tools/StreamsResetter.java | 505 ++--
.../java/org/apache/kafka/tools}/ToolsUtils.java | 3 +-
.../apache/kafka/tools/TransactionsCommand.java | 9 +-
.../org/apache/kafka/tools/VerifiableProducer.java | 1 +
.../kafka/tools/DeleteRecordsCommandTest.java | 182 ++
.../apache/kafka}/tools/StreamsResetterTest.java | 26 +-
221 files changed, 11081 insertions(+), 2143 deletions(-)
copy
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/{ApplicationEvent.java
=> AssignmentChangeApplicationEvent.java} (59%)
copy core/src/main/scala/kafka/common/AdminCommandFailedException.scala =>
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/NewTopicsMetadataUpdateRequestEvent.java
(65%)
copy
clients/src/main/java/org/apache/kafka/{clients/consumer/internals/events/ApplicationEvent.java
=> common/errors/StaleMemberEpochException.java} (55%)
rename {tools/src/main/java/org/apache/kafka/tools =>
clients/src/main/java/org/apache/kafka/common/utils}/ThroughputThrottler.java
(99%)
create mode 100644
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/ServiceLoaderScanner.java
create mode 100644
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/InternalSinkRecordTest.java
create mode 100644
connect/runtime/src/test/resources/test-plugins/aliased-static-field/META-INF/services/org.apache.kafka.connect.storage.Converter
create mode 100644
connect/runtime/src/test/resources/test-plugins/always-throw-exception/META-INF/services/org.apache.kafka.connect.storage.Converter
create mode 100644
connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF/services/org.apache.kafka.connect.sink.SinkConnector
create mode 100644
connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF/services/org.apache.kafka.connect.storage.Converter
create mode 100644
connect/runtime/src/test/resources/test-plugins/multiple-plugins-in-jar/META-INF/services/org.apache.kafka.connect.storage.Converter
create mode 100644
connect/runtime/src/test/resources/test-plugins/read-version-from-resource-v1/META-INF/services/org.apache.kafka.connect.storage.Converter
create mode 100644
connect/runtime/src/test/resources/test-plugins/read-version-from-resource-v2/META-INF/services/org.apache.kafka.connect.storage.Converter
create mode 100644
connect/runtime/src/test/resources/test-plugins/sampling-configurable/META-INF/services/org.apache.kafka.connect.storage.Converter
create mode 100644
connect/runtime/src/test/resources/test-plugins/sampling-connector/META-INF/services/org.apache.kafka.connect.sink.SinkConnector
create mode 100644
connect/runtime/src/test/resources/test-plugins/sampling-converter/META-INF/services/org.apache.kafka.connect.storage.Converter
create mode 100644
connect/runtime/src/test/resources/test-plugins/sampling-header-converter/META-INF/services/org.apache.kafka.connect.storage.HeaderConverter
create mode 100644
connect/runtime/src/test/resources/test-plugins/service-loader/META-INF/services/org.apache.kafka.connect.storage.Converter
create mode 100644
connect/runtime/src/test/resources/test-plugins/subclass-of-classpath/META-INF/services/org.apache.kafka.connect.storage.Converter
delete mode 100644 core/src/main/scala/kafka/admin/DeleteRecordsCommand.scala
delete mode 100644 core/src/main/scala/kafka/utils/TopicFilter.scala
delete mode 100644 core/src/test/scala/unit/kafka/utils/TopicFilterTest.scala
create mode 100644
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetAndMetadata.java
delete mode 100644
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/generic/Protocol.java
create mode 100644
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetAndMetadataTest.java
delete mode 100644 licenses/classgraph-MIT
rename core/src/main/scala/kafka/common/AdminCommandFailedException.scala =>
server-common/src/main/java/org/apache/kafka/server/common/AdminCommandFailedException.java
(60%)
rename core/src/main/scala/kafka/admin/AdminOperationException.scala =>
server-common/src/main/java/org/apache/kafka/server/common/AdminOperationException.java
(61%)
create mode 100644
server-common/src/main/java/org/apache/kafka/server/util/Json.java
create mode 100644
server-common/src/main/java/org/apache/kafka/server/util/PartitionFilter.java
create mode 100644
server-common/src/main/java/org/apache/kafka/server/util/TopicFilter.java
create mode 100644
server-common/src/main/java/org/apache/kafka/server/util/TopicPartitionFilter.java
create mode 100644
server-common/src/main/java/org/apache/kafka/server/util/json/DecodeJson.java
create mode 100644
server-common/src/main/java/org/apache/kafka/server/util/json/JsonArray.java
create mode 100644
server-common/src/main/java/org/apache/kafka/server/util/json/JsonObject.java
create mode 100644
server-common/src/main/java/org/apache/kafka/server/util/json/JsonValue.java
create mode 100644
server-common/src/test/java/org/apache/kafka/server/util/JsonTest.java
create mode 100644
server-common/src/test/java/org/apache/kafka/server/util/TopicFilterTest.java
create mode 100644
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogLeaderEpochStateTest.java
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java
rename streams/src/main/java/org/apache/kafka/streams/processor/internals/{ =>
assignment}/RackAwareTaskAssignor.java (98%)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/GraphTest.java
create mode 100644
tools/src/main/java/org/apache/kafka/tools/DeleteRecordsCommand.java
rename {server-common/src/main/java/org/apache/kafka/server/util =>
tools/src/main/java/org/apache/kafka/tools}/ToolsUtils.java (99%)
create mode 100644
tools/src/test/java/org/apache/kafka/tools/DeleteRecordsCommandTest.java
rename {streams/src/test/java/org/apache/kafka/streams =>
tools/src/test/java/org/apache/kafka}/tools/StreamsResetterTest.java (97%)
