Path	Lines of Code
benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/BatchedConsumer.scala	51
benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/Benchmarks.scala	114
benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/NoCommitBackpressure.scala	23
benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableProducer.scala	35
benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/Producer.scala	45
benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/SpecBase.scala	13
benchmarks/src/it/scala/org/apache/pekko/kafka/benchmarks/Transactions.scala	36
benchmarks/src/main/resources/logback.xml	25
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/CsvFormatter.scala	100
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/FixtureGen.scala	3
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/InflightMetrics.scala	202
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerBenchmarks.scala	157
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaConsumerFixtureGen.scala	30
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaProducerBenchmarks.scala	28
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaProducerFixtureGen.scala	26
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaTransactionBenchmarks.scala	71
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/KafkaTransactionFixtureGen.scala	59
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PekkoConnectorsCommittableSinkFixtures.scala	114
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PerfFixtureHelpers.scala	91
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerBenchmarks.scala	136
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerFixtures.scala	47
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaProducerBenchmarks.scala	47
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaProducerFixtures.scala	42
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionBenchmarks.scala	50
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionFixtures.scala	64
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/Timed.scala	101
benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/app/RunTestCommand.scala	8