Path	Lines of Code
tools/src/main/java/org/apache/kafka/tools/AclCommand.java	531
tools/src/main/java/org/apache/kafka/tools/AdminCommandFailedException.java	9
tools/src/main/java/org/apache/kafka/tools/AdminOperationException.java	9
tools/src/main/java/org/apache/kafka/tools/BrokerApiVersionsCommand.java	254
tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java	471
tools/src/main/java/org/apache/kafka/tools/ClientMetricsCommand.java	296
tools/src/main/java/org/apache/kafka/tools/ClusterTool.java	165
tools/src/main/java/org/apache/kafka/tools/ConnectPluginPath.java	373
tools/src/main/java/org/apache/kafka/tools/ConsoleProducer.java	292
tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java	334
tools/src/main/java/org/apache/kafka/tools/DelegationTokenCommand.java	237
tools/src/main/java/org/apache/kafka/tools/DeleteRecordsCommand.java	137
tools/src/main/java/org/apache/kafka/tools/EndToEndLatency.java	164
tools/src/main/java/org/apache/kafka/tools/FeatureCommand.java	398
tools/src/main/java/org/apache/kafka/tools/GetOffsetShell.java	298
tools/src/main/java/org/apache/kafka/tools/GroupsCommand.java	241
tools/src/main/java/org/apache/kafka/tools/JmxTool.java	369
tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java	323
tools/src/main/java/org/apache/kafka/tools/LineMessageReader.java	161
tools/src/main/java/org/apache/kafka/tools/LogDirsCommand.java	177
tools/src/main/java/org/apache/kafka/tools/ManifestWorkspace.java	455
tools/src/main/java/org/apache/kafka/tools/MetadataQuorumCommand.java	443
tools/src/main/java/org/apache/kafka/tools/OAuthCompatibilityTool.java	305
tools/src/main/java/org/apache/kafka/tools/PrintVersionAndExitAction.java	29
tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java	441
tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java	255
tools/src/main/java/org/apache/kafka/tools/ReplicaVerificationTool.java	602
tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java	384
tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java	612
tools/src/main/java/org/apache/kafka/tools/TerseException.java	6
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java	111
tools/src/main/java/org/apache/kafka/tools/TopicCommand.java	834
tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java	341
tools/src/main/java/org/apache/kafka/tools/TransactionsCommand.java	873
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java	547
tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java	390
tools/src/main/java/org/apache/kafka/tools/VerifiableShareConsumer.java	514
tools/src/main/java/org/apache/kafka/tools/consumer/ConsoleConsumer.java	163
tools/src/main/java/org/apache/kafka/tools/consumer/ConsoleConsumerOptions.java	338
tools/src/main/java/org/apache/kafka/tools/consumer/ConsoleShareConsumer.java	141
tools/src/main/java/org/apache/kafka/tools/consumer/ConsoleShareConsumerOptions.java	222
tools/src/main/java/org/apache/kafka/tools/consumer/CoordinatorRecordMessageFormatter.java	63
tools/src/main/java/org/apache/kafka/tools/consumer/DefaultMessageFormatter.java	187
tools/src/main/java/org/apache/kafka/tools/consumer/GroupMetadataMessageFormatter.java	27
tools/src/main/java/org/apache/kafka/tools/consumer/LoggingMessageFormatter.java	27
tools/src/main/java/org/apache/kafka/tools/consumer/NoOpMessageFormatter.java	9
tools/src/main/java/org/apache/kafka/tools/consumer/OffsetsMessageFormatter.java	28
tools/src/main/java/org/apache/kafka/tools/consumer/ShareGroupMessageFormatter.java	33
tools/src/main/java/org/apache/kafka/tools/consumer/TransactionLogMessageFormatter.java	22
tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java	1164
tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandOptions.java	244
tools/src/main/java/org/apache/kafka/tools/consumer/group/CsvUtils.java	102
tools/src/main/java/org/apache/kafka/tools/consumer/group/GroupInformation.java	30
tools/src/main/java/org/apache/kafka/tools/consumer/group/MemberAssignmentState.java	42
tools/src/main/java/org/apache/kafka/tools/consumer/group/PartitionAssignmentState.java	41
tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommand.java	501
tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommandOptions.java	175
tools/src/main/java/org/apache/kafka/tools/consumer/group/share/ShareGroupStateMessageFormatter.java	23
tools/src/main/java/org/apache/kafka/tools/filter/PartitionFilter.java	37
tools/src/main/java/org/apache/kafka/tools/filter/TopicFilter.java	47
tools/src/main/java/org/apache/kafka/tools/filter/TopicPartitionFilter.java	38
tools/src/main/java/org/apache/kafka/tools/reassign/ActiveMoveState.java	27
tools/src/main/java/org/apache/kafka/tools/reassign/CancelledMoveState.java	25
tools/src/main/java/org/apache/kafka/tools/reassign/CompletedMoveState.java	23
tools/src/main/java/org/apache/kafka/tools/reassign/LogDirMoveState.java	4
tools/src/main/java/org/apache/kafka/tools/reassign/MissingLogDirMoveState.java	23
tools/src/main/java/org/apache/kafka/tools/reassign/MissingReplicaMoveState.java	23
tools/src/main/java/org/apache/kafka/tools/reassign/PartitionMove.java	22
tools/src/main/java/org/apache/kafka/tools/reassign/PartitionReassignmentState.java	24
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java	1054
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommandOptions.java	91
tools/src/main/java/org/apache/kafka/tools/reassign/VerifyAssignmentResult.java	37
tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java	331
tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommandOptions.java	95
tools/tools-api/src/main/java/org/apache/kafka/tools/api/Decoder.java	5
tools/tools-api/src/main/java/org/apache/kafka/tools/api/DefaultDecoder.java	7
tools/tools-api/src/main/java/org/apache/kafka/tools/api/IntegerDecoder.java	8
tools/tools-api/src/main/java/org/apache/kafka/tools/api/LongDecoder.java	8
tools/tools-api/src/main/java/org/apache/kafka/tools/api/RecordReader.java	12
tools/tools-api/src/main/java/org/apache/kafka/tools/api/StringDecoder.java	8
tools/tools-api/src/main/java/org/apache/kafka/tools/api/package-info.java	1