Path	Lines of Code
tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java	450
tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java	344
tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java	257
tools/src/main/java/org/apache/kafka/tools/ThroughputThrottler.java	67
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java	36
tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java	256
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java	496
tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java	188
tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java	364
tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java	106
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java	131
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentRestResource.java	55
tools/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java	403
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicNode.java	83
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicPlatform.java	82
tools/src/main/java/org/apache/kafka/trogdor/basic/BasicTopology.java	34
tools/src/main/java/org/apache/kafka/trogdor/common/JsonUtil.java	27
tools/src/main/java/org/apache/kafka/trogdor/common/Node.java	24
tools/src/main/java/org/apache/kafka/trogdor/common/Platform.java	33
tools/src/main/java/org/apache/kafka/trogdor/common/ThreadUtils.java	23
tools/src/main/java/org/apache/kafka/trogdor/common/Topology.java	20
tools/src/main/java/org/apache/kafka/trogdor/common/WorkerUtils.java	88
tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java	110
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java	142
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorRestResource.java	62
tools/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java	201
tools/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java	351
tools/src/main/java/org/apache/kafka/trogdor/fault/FilesUnreadableFaultSpec.java	52
tools/src/main/java/org/apache/kafka/trogdor/fault/Kibosh.java	144
tools/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultController.java	14
tools/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultWorker.java	30
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultController.java	20
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultSpec.java	47
tools/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultWorker.java	53
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultController.java	14
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultSpec.java	38
tools/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultWorker.java	55
tools/src/main/java/org/apache/kafka/trogdor/rest/AgentStatusResponse.java	22
tools/src/main/java/org/apache/kafka/trogdor/rest/CoordinatorShutdownRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/CoordinatorStatusResponse.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateTaskRequest.java	22
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateTaskResponse.java	15
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateWorkerRequest.java	22
tools/src/main/java/org/apache/kafka/trogdor/rest/CreateWorkerResponse.java	15
tools/src/main/java/org/apache/kafka/trogdor/rest/Empty.java	23
tools/src/main/java/org/apache/kafka/trogdor/rest/ErrorResponse.java	39
tools/src/main/java/org/apache/kafka/trogdor/rest/JsonRestServer.java	187
tools/src/main/java/org/apache/kafka/trogdor/rest/Message.java	19
tools/src/main/java/org/apache/kafka/trogdor/rest/RestExceptionMapper.java	49
tools/src/main/java/org/apache/kafka/trogdor/rest/StopTaskRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/StopTaskResponse.java	15
tools/src/main/java/org/apache/kafka/trogdor/rest/StopWorkerRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/StopWorkerResponse.java	15
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskDone.java	38
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskPending.java	10
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskRunning.java	17
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskState.java	24
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskStopping.java	17
tools/src/main/java/org/apache/kafka/trogdor/rest/TasksResponse.java	15
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerDone.java	44
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerReceiving.java	10
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerRunning.java	30
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStarting.java	10
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerState.java	41
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStopping.java	34
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskController.java	14
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskSpec.java	18
tools/src/main/java/org/apache/kafka/trogdor/task/NoOpTaskWorker.java	22
tools/src/main/java/org/apache/kafka/trogdor/task/TaskController.java	6
tools/src/main/java/org/apache/kafka/trogdor/task/TaskSpec.java	42
tools/src/main/java/org/apache/kafka/trogdor/task/TaskWorker.java	9
tools/src/main/java/org/apache/kafka/trogdor/workload/Histogram.java	127
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java	79
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java	248
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java	286
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkloadSpec.java	66
tools/src/main/java/org/apache/kafka/trogdor/workload/Throttle.java	41