This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 79b9c44acdb KAFKA-10787 Apply spotless to connect module (#16299)
add 46eb0814f63 KAFKA-10787 Apply spotless to log4j-appender, trogdor,
jmh-benchmarks, examples, shell and generator (#16296)
No new revisions were added by this update.
Summary of changes:
build.gradle | 8 +-----
.../org/apache/kafka/message/MessageGenerator.java | 1 +
.../org/apache/kafka/message/CodeBufferTest.java | 2 +-
.../apache/kafka/message/MessageGeneratorTest.java | 2 +-
.../kafka/message/VersionConditionalTest.java | 2 +-
.../org/apache/kafka/message/VersionsTest.java | 2 +-
.../apache/kafka/jmh/acl/AuthorizerBenchmark.java | 7 ++++--
.../jmh/acl/StandardAuthorizerUpdateBenchmark.java | 1 +
.../jmh/assignor/ClientSideAssignorBenchmark.java | 1 +
.../jmh/assignor/ServerSideAssignorBenchmark.java | 13 +++++-----
.../assignor/TargetAssignmentBuilderBenchmark.java | 7 +++---
.../apache/kafka/jmh/cache/LRUCacheBenchmark.java | 4 ++-
.../kafka/jmh/common/FetchRequestBenchmark.java | 2 ++
.../kafka/jmh/common/FetchResponseBenchmark.java | 3 ++-
.../ImplicitLinkedHashCollectionBenchmark.java | 1 +
.../jmh/common/ListOffsetRequestBenchmark.java | 2 ++
.../kafka/jmh/common/ProduceRequestBenchmark.java | 2 ++
.../apache/kafka/jmh/common/TopicBenchmark.java | 1 +
.../kafka/jmh/connect/JsonConverterBenchmark.java | 1 +
.../kafka/jmh/connect/ReplaceFieldBenchmark.java | 1 +
.../apache/kafka/jmh/connect/ValuesBenchmark.java | 1 +
.../jmh/consumer/SubscriptionStateBenchmark.java | 1 +
.../jmh/fetcher/ReplicaFetcherThreadBenchmark.java | 17 +++++++------
.../jmh/fetchsession/FetchSessionBenchmark.java | 3 ++-
.../metadata/KRaftMetadataRequestBenchmark.java | 4 ++-
.../jmh/metadata/MetadataRequestBenchmark.java | 7 ++++--
.../TopicsImageSingleRecordChangeBenchmark.java | 1 +
.../metadata/TopicsImageSnapshotLoadBenchmark.java | 1 +
.../metadata/TopicsImageZonalOutageBenchmark.java | 1 +
.../partition/PartitionMakeFollowerBenchmark.java | 7 ++++--
.../UpdateFollowerFetchStateBenchmark.java | 7 ++++--
.../jmh/producer/ProducerRecordBenchmark.java | 1 +
.../jmh/producer/ProducerRequestBenchmark.java | 1 +
.../jmh/producer/ProducerResponseBenchmark.java | 1 +
.../kafka/jmh/record/BaseRecordBatchBenchmark.java | 2 ++
.../CompressedRecordBatchValidationBenchmark.java | 1 +
.../jmh/record/RecordBatchIterationBenchmark.java | 1 +
...UncompressedRecordBatchValidationBenchmark.java | 1 +
.../apache/kafka/jmh/server/CheckpointBench.java | 16 ++++++------
.../kafka/jmh/server/PartitionCreationBench.java | 7 ++++--
.../jmh/storage/ProducerStateManagerBench.java | 1 +
.../jmh/timeline/TimelineHashMapBenchmark.java | 1 +
.../apache/kafka/jmh/util/ByteUtilsBenchmark.java | 11 ++++----
.../org/apache/kafka/jmh/util/Crc32CBenchmark.java | 7 +++---
.../kafka/log4jappender/KafkaLog4jAppender.java | 3 ++-
.../log4jappender/KafkaLog4jAppenderTest.java | 8 +++---
.../log4jappender/MockKafkaLog4jAppender.java | 1 +
.../org/apache/kafka/shell/InteractiveShell.java | 1 +
.../java/org/apache/kafka/shell/MetadataShell.java | 9 ++++---
.../kafka/shell/command/CatCommandHandler.java | 6 +++--
.../kafka/shell/command/CdCommandHandler.java | 6 +++--
.../apache/kafka/shell/command/CommandUtils.java | 1 +
.../org/apache/kafka/shell/command/Commands.java | 6 +++--
.../kafka/shell/command/ExitCommandHandler.java | 6 +++--
.../kafka/shell/command/FindCommandHandler.java | 6 +++--
.../kafka/shell/command/HelpCommandHandler.java | 6 +++--
.../kafka/shell/command/HistoryCommandHandler.java | 6 +++--
.../kafka/shell/command/LsCommandHandler.java | 6 +++--
.../kafka/shell/command/ManCommandHandler.java | 6 +++--
.../kafka/shell/command/PwdCommandHandler.java | 6 +++--
.../kafka/shell/command/TreeCommandHandler.java | 6 +++--
.../kafka/shell/state/MetadataShellPublisher.java | 1 +
.../kafka/shell/MetadataShellIntegrationTest.java | 16 ++++++------
.../apache/kafka/shell/command/CommandTest.java | 4 +--
.../kafka/shell/command/CommandUtilsTest.java | 6 ++---
.../kafka/shell/command/LsCommandHandlerTest.java | 5 ++--
.../apache/kafka/shell/glob/GlobComponentTest.java | 6 ++---
.../apache/kafka/shell/glob/GlobVisitorTest.java | 7 +++---
.../java/org/apache/kafka/trogdor/agent/Agent.java | 17 +++++++------
.../apache/kafka/trogdor/agent/AgentClient.java | 21 +++++++++-------
.../kafka/trogdor/agent/AgentRestResource.java | 3 ++-
.../apache/kafka/trogdor/agent/WorkerManager.java | 3 ++-
.../org/apache/kafka/trogdor/basic/BasicNode.java | 3 ++-
.../apache/kafka/trogdor/basic/BasicPlatform.java | 4 ++-
.../apache/kafka/trogdor/basic/BasicTopology.java | 3 ++-
.../org/apache/kafka/trogdor/common/Platform.java | 6 ++---
.../apache/kafka/trogdor/common/WorkerUtils.java | 1 +
.../kafka/trogdor/coordinator/Coordinator.java | 10 +++++---
.../trogdor/coordinator/CoordinatorClient.java | 29 ++++++++++++----------
.../coordinator/CoordinatorRestResource.java | 7 +++---
.../kafka/trogdor/coordinator/NodeManager.java | 1 +
.../kafka/trogdor/coordinator/TaskManager.java | 12 +++++----
.../trogdor/fault/DegradedNetworkFaultSpec.java | 5 ++--
.../trogdor/fault/DegradedNetworkFaultWorker.java | 4 ++-
.../trogdor/fault/FilesUnreadableFaultSpec.java | 5 ++--
.../org/apache/kafka/trogdor/fault/Kibosh.java | 3 ++-
.../kafka/trogdor/fault/KiboshFaultWorker.java | 4 ++-
.../trogdor/fault/NetworkPartitionFaultSpec.java | 5 ++--
.../trogdor/fault/NetworkPartitionFaultWorker.java | 4 ++-
.../trogdor/fault/ProcessStopFaultController.java | 1 +
.../kafka/trogdor/fault/ProcessStopFaultSpec.java | 5 ++--
.../trogdor/fault/ProcessStopFaultWorker.java | 4 ++-
.../kafka/trogdor/rest/CreateTaskRequest.java | 3 ++-
.../kafka/trogdor/rest/CreateWorkerRequest.java | 3 ++-
.../java/org/apache/kafka/trogdor/rest/Empty.java | 3 ++-
.../apache/kafka/trogdor/rest/ErrorResponse.java | 3 ++-
.../apache/kafka/trogdor/rest/JsonRestServer.java | 5 ++--
.../kafka/trogdor/rest/RestExceptionMapper.java | 6 +++--
.../org/apache/kafka/trogdor/rest/TaskDone.java | 3 ++-
.../org/apache/kafka/trogdor/rest/TaskPending.java | 3 ++-
.../org/apache/kafka/trogdor/rest/TaskRunning.java | 3 ++-
.../org/apache/kafka/trogdor/rest/TaskState.java | 3 ++-
.../apache/kafka/trogdor/rest/TaskStopping.java | 3 ++-
.../org/apache/kafka/trogdor/rest/WorkerDone.java | 3 ++-
.../apache/kafka/trogdor/rest/WorkerReceiving.java | 3 ++-
.../apache/kafka/trogdor/rest/WorkerRunning.java | 3 ++-
.../apache/kafka/trogdor/rest/WorkerStarting.java | 3 ++-
.../org/apache/kafka/trogdor/rest/WorkerState.java | 5 ++--
.../apache/kafka/trogdor/rest/WorkerStopping.java | 3 ++-
.../apache/kafka/trogdor/task/NoOpTaskWorker.java | 4 ++-
.../org/apache/kafka/trogdor/task/TaskSpec.java | 3 ++-
.../trogdor/workload/ConfigurableProducerSpec.java | 6 +++--
.../workload/ConfigurableProducerWorker.java | 8 +++---
.../trogdor/workload/ConnectionStressSpec.java | 5 ++--
.../trogdor/workload/ConnectionStressWorker.java | 8 +++---
.../trogdor/workload/ConstantFlushGenerator.java | 5 ++--
.../workload/ConstantThroughputGenerator.java | 3 ++-
.../kafka/trogdor/workload/ConsumeBenchSpec.java | 12 ++++-----
.../kafka/trogdor/workload/ConsumeBenchWorker.java | 17 +++++++------
.../trogdor/workload/ExternalCommandSpec.java | 8 +++---
.../trogdor/workload/ExternalCommandWorker.java | 17 +++++++------
.../kafka/trogdor/workload/FlushGenerator.java | 3 ++-
.../trogdor/workload/GaussianFlushGenerator.java | 6 +++--
.../workload/GaussianThroughputGenerator.java | 4 ++-
.../GaussianTimestampConstantPayloadGenerator.java | 3 ++-
.../GaussianTimestampRandomPayloadGenerator.java | 3 ++-
.../kafka/trogdor/workload/PartitionsSpec.java | 5 ++--
.../kafka/trogdor/workload/ProduceBenchSpec.java | 5 ++--
.../kafka/trogdor/workload/ProduceBenchWorker.java | 8 +++---
.../kafka/trogdor/workload/RandomComponent.java | 1 -
.../kafka/trogdor/workload/RecordProcessor.java | 4 +--
.../kafka/trogdor/workload/RoundTripWorker.java | 8 +++---
.../trogdor/workload/RoundTripWorkloadSpec.java | 5 ++--
.../trogdor/workload/SustainedConnectionSpec.java | 5 ++--
.../workload/SustainedConnectionWorker.java | 8 +++---
.../TimeIntervalTransactionsGenerator.java | 3 ++-
.../TimestampConstantPayloadGenerator.java | 5 ++--
.../workload/TimestampRandomPayloadGenerator.java | 5 ++--
.../trogdor/workload/TimestampRecordProcessor.java | 9 ++++---
.../apache/kafka/trogdor/workload/TopicsSpec.java | 5 ++--
.../org/apache/kafka/trogdor/agent/AgentTest.java | 16 ++++++------
.../kafka/trogdor/basic/BasicPlatformTest.java | 5 ++--
.../trogdor/common/CapturingCommandRunner.java | 1 +
.../apache/kafka/trogdor/common/ExpectedTasks.java | 6 +++--
.../trogdor/common/JsonSerializationTest.java | 7 +++---
.../apache/kafka/trogdor/common/JsonUtilTest.java | 10 +++++---
.../kafka/trogdor/common/MiniTrogdorCluster.java | 2 +-
.../kafka/trogdor/common/StringExpanderTest.java | 6 ++---
.../kafka/trogdor/common/StringFormatterTest.java | 4 +--
.../apache/kafka/trogdor/common/TopologyTest.java | 10 ++++----
.../kafka/trogdor/common/WorkerUtilsTest.java | 7 +++---
.../trogdor/coordinator/CoordinatorClientTest.java | 6 +++--
.../kafka/trogdor/coordinator/CoordinatorTest.java | 11 +++++---
.../trogdor/rest/RestExceptionMapperTest.java | 12 +++++----
.../kafka/trogdor/task/SampleTaskWorker.java | 3 ++-
.../apache/kafka/trogdor/task/TaskSpecTest.java | 4 ++-
.../trogdor/workload/ConsumeBenchSpecTest.java | 11 ++++----
.../workload/ExternalCommandWorkerTest.java | 14 ++++++-----
.../kafka/trogdor/workload/HistogramTest.java | 5 ++--
.../trogdor/workload/PayloadGeneratorTest.java | 15 +++++------
.../kafka/trogdor/workload/ThrottleTest.java | 10 ++++----
.../TimeIntervalTransactionsGeneratorTest.java | 5 ++--
.../kafka/trogdor/workload/TopicsSpecTest.java | 11 ++++----
163 files changed, 541 insertions(+), 347 deletions(-)
