Path	Lines of Code
tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java	459
tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java	343
tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java	256
tools/src/main/java/org/apache/kafka/tools/ThroughputThrottler.java	67
tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java	30
tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java	312
tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java	532
tools/src/main/java/org/apache/kafka/tools/VerifiableLog4jAppender.java	183
tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java	400
tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java	186
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java	271
tools/src/main/java/org/apache/kafka/trogdor/agent/AgentRestResource.java	71
tools/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java	498
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	50
tools/src/main/java/org/apache/kafka/trogdor/common/Node.java	26
tools/src/main/java/org/apache/kafka/trogdor/common/Platform.java	33
tools/src/main/java/org/apache/kafka/trogdor/common/StringExpander.java	30
tools/src/main/java/org/apache/kafka/trogdor/common/StringFormatter.java	68
tools/src/main/java/org/apache/kafka/trogdor/common/Topology.java	20
tools/src/main/java/org/apache/kafka/trogdor/common/WorkerUtils.java	219
tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java	124
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java	460
tools/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorRestResource.java	109
tools/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java	237
tools/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java	484
tools/src/main/java/org/apache/kafka/trogdor/fault/DegradedNetworkFaultSpec.java	63
tools/src/main/java/org/apache/kafka/trogdor/fault/DegradedNetworkFaultWorker.java	113
tools/src/main/java/org/apache/kafka/trogdor/fault/FilesUnreadableFaultSpec.java	53
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	37
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	60
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	62
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/CreateWorkerRequest.java	29
tools/src/main/java/org/apache/kafka/trogdor/rest/DestroyTaskRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/DestroyWorkerRequest.java	14
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	190
tools/src/main/java/org/apache/kafka/trogdor/rest/Message.java	19
tools/src/main/java/org/apache/kafka/trogdor/rest/RequestConflictException.java	10
tools/src/main/java/org/apache/kafka/trogdor/rest/RestExceptionMapper.java	56
tools/src/main/java/org/apache/kafka/trogdor/rest/StopTaskRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/StopWorkerRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskDone.java	44
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskPending.java	15
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskRequest.java	14
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskRunning.java	23
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskState.java	33
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskStateType.java	19
tools/src/main/java/org/apache/kafka/trogdor/rest/TaskStopping.java	23
tools/src/main/java/org/apache/kafka/trogdor/rest/TasksRequest.java	76
tools/src/main/java/org/apache/kafka/trogdor/rest/TasksResponse.java	18
tools/src/main/java/org/apache/kafka/trogdor/rest/UptimeResponse.java	21
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerDone.java	47
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerReceiving.java	17
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerRunning.java	33
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStarting.java	17
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerState.java	46
tools/src/main/java/org/apache/kafka/trogdor/rest/WorkerStopping.java	37
tools/src/main/java/org/apache/kafka/trogdor/task/AgentWorkerStatusTracker.java	16
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	26
tools/src/main/java/org/apache/kafka/trogdor/task/TaskController.java	6
tools/src/main/java/org/apache/kafka/trogdor/task/TaskSpec.java	50
tools/src/main/java/org/apache/kafka/trogdor/task/TaskWorker.java	8
tools/src/main/java/org/apache/kafka/trogdor/task/WorkerStatusTracker.java	5
tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressSpec.java	72
tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java	263
tools/src/main/java/org/apache/kafka/trogdor/workload/ConstantPayloadGenerator.java	29
tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchSpec.java	137
tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java	440
tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandSpec.java	56
tools/src/main/java/org/apache/kafka/trogdor/workload/ExternalCommandWorker.java	282
tools/src/main/java/org/apache/kafka/trogdor/workload/Histogram.java	127
tools/src/main/java/org/apache/kafka/trogdor/workload/NullPayloadGenerator.java	11
tools/src/main/java/org/apache/kafka/trogdor/workload/PartitionsSpec.java	90
tools/src/main/java/org/apache/kafka/trogdor/workload/PayloadGenerator.java	16
tools/src/main/java/org/apache/kafka/trogdor/workload/PayloadIterator.java	27
tools/src/main/java/org/apache/kafka/trogdor/workload/PayloadKeyType.java	12
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchSpec.java	126
tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java	341
tools/src/main/java/org/apache/kafka/trogdor/workload/RandomComponent.java	21
tools/src/main/java/org/apache/kafka/trogdor/workload/RandomComponentPayloadGenerator.java	56
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorker.java	388
tools/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkloadSpec.java	95
tools/src/main/java/org/apache/kafka/trogdor/workload/SequentialPayloadGenerator.java	34
tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionSpec.java	121
tools/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionWorker.java	396
tools/src/main/java/org/apache/kafka/trogdor/workload/Throttle.java	46
tools/src/main/java/org/apache/kafka/trogdor/workload/TimeIntervalTransactionsGenerator.java	38
tools/src/main/java/org/apache/kafka/trogdor/workload/TopicsSpec.java	43
tools/src/main/java/org/apache/kafka/trogdor/workload/TransactionGenerator.java	16
tools/src/main/java/org/apache/kafka/trogdor/workload/UniformRandomPayloadGenerator.java	54
tools/src/main/java/org/apache/kafka/trogdor/workload/UniformTransactionsGenerator.java	30