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
build.sbt	134
cluster-sharding/src/main/scala/org/apache/pekko/kafka/cluster/sharding/KafkaClusterSharding.scala	174
core/src/main/scala/org/apache/pekko/kafka/CommitTimeoutException.scala	3
core/src/main/scala/org/apache/pekko/kafka/CommitterSettings.scala	100
core/src/main/scala/org/apache/pekko/kafka/ConnectionCheckerSettings.scala	53
core/src/main/scala/org/apache/pekko/kafka/ConsumerFailed.scala	20
core/src/main/scala/org/apache/pekko/kafka/ConsumerMessage.scala	101
core/src/main/scala/org/apache/pekko/kafka/ConsumerSettings.scala	330
core/src/main/scala/org/apache/pekko/kafka/KafkaConnectionFailed.scala	4
core/src/main/scala/org/apache/pekko/kafka/KafkaConsumerActor.scala	16
core/src/main/scala/org/apache/pekko/kafka/Metadata.scala	97
core/src/main/scala/org/apache/pekko/kafka/OffsetResetProtectionSettings.scala	48
core/src/main/scala/org/apache/pekko/kafka/ProducerMessage.scala	68
core/src/main/scala/org/apache/pekko/kafka/ProducerSettings.scala	223
core/src/main/scala/org/apache/pekko/kafka/RestrictedConsumer.scala	27
core/src/main/scala/org/apache/pekko/kafka/Subscriptions.scala	119
core/src/main/scala/org/apache/pekko/kafka/internal/BaseSingleSourceLogic.scala	97
core/src/main/scala/org/apache/pekko/kafka/internal/CommitCollectorStage.scala	122
core/src/main/scala/org/apache/pekko/kafka/internal/CommitObservationLogic.scala	54
core/src/main/scala/org/apache/pekko/kafka/internal/CommitTrigger.scala	19
core/src/main/scala/org/apache/pekko/kafka/internal/CommittableSources.scala	207
core/src/main/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkStage.scala	214
core/src/main/scala/org/apache/pekko/kafka/internal/ConfigSettings.scala	46
core/src/main/scala/org/apache/pekko/kafka/internal/ConnectionChecker.scala	52
core/src/main/scala/org/apache/pekko/kafka/internal/ConsumerProgressTracking.scala	84
core/src/main/scala/org/apache/pekko/kafka/internal/ConsumerResetProtection.scala	107
core/src/main/scala/org/apache/pekko/kafka/internal/ControlImplementations.scala	84
core/src/main/scala/org/apache/pekko/kafka/internal/DefaultProducerStage.scala	156
core/src/main/scala/org/apache/pekko/kafka/internal/DeferredProducer.scala	74
core/src/main/scala/org/apache/pekko/kafka/internal/ExternalSingleSourceLogic.scala	21
core/src/main/scala/org/apache/pekko/kafka/internal/KafkaConsumerActor.scala	620
core/src/main/scala/org/apache/pekko/kafka/internal/KafkaSourceStage.scala	18
core/src/main/scala/org/apache/pekko/kafka/internal/LoggingWithId.scala	41
core/src/main/scala/org/apache/pekko/kafka/internal/MessageBuilder.scala	183
core/src/main/scala/org/apache/pekko/kafka/internal/PartitionAssignmentHelpers.scala	85
core/src/main/scala/org/apache/pekko/kafka/internal/PlainSources.scala	62
core/src/main/scala/org/apache/pekko/kafka/internal/ProducerStage.scala	21
core/src/main/scala/org/apache/pekko/kafka/internal/SingleSourceLogic.scala	71
core/src/main/scala/org/apache/pekko/kafka/internal/SourceLogicBuffer.scala	22
core/src/main/scala/org/apache/pekko/kafka/internal/SourceLogicSubscription.scala	46
core/src/main/scala/org/apache/pekko/kafka/internal/SubSourceLogic.scala	359
core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalProducerStage.scala	208
core/src/main/scala/org/apache/pekko/kafka/internal/TransactionalSources.scala	335
core/src/main/scala/org/apache/pekko/kafka/javadsl/Committer.scala	31
core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala	217
core/src/main/scala/org/apache/pekko/kafka/javadsl/DiscoverySupport.scala	43
core/src/main/scala/org/apache/pekko/kafka/javadsl/MetadataClient.scala	85
core/src/main/scala/org/apache/pekko/kafka/javadsl/PartitionAssignmentHandler.scala	10
core/src/main/scala/org/apache/pekko/kafka/javadsl/Producer.scala	94
core/src/main/scala/org/apache/pekko/kafka/javadsl/SendProducer.scala	22
core/src/main/scala/org/apache/pekko/kafka/javadsl/Transactional.scala	61
core/src/main/scala/org/apache/pekko/kafka/scaladsl/Committer.scala	46
core/src/main/scala/org/apache/pekko/kafka/scaladsl/Consumer.scala	144
core/src/main/scala/org/apache/pekko/kafka/scaladsl/DiscoverySupport.scala	81
core/src/main/scala/org/apache/pekko/kafka/scaladsl/MetadataClient.scala	89
core/src/main/scala/org/apache/pekko/kafka/scaladsl/PartitionAssignmentHandler.scala	10
core/src/main/scala/org/apache/pekko/kafka/scaladsl/Producer.scala	110
core/src/main/scala/org/apache/pekko/kafka/scaladsl/SendProducer.scala	63
core/src/main/scala/org/apache/pekko/kafka/scaladsl/Transactional.scala	81
project/AddMetaInfLicenseFiles.scala	16
project/AutomaticModuleName.scala	7
project/CopyrightHeader.scala	96
project/CopyrightHeaderForBuild.scala	17
project/CopyrightHeaderForProtobuf.scala	16
project/Dependencies.scala	41
project/LicenseReport.scala	23
project/ParadoxSettings.scala	54
project/ProjectSettings.scala	107
project/ResolverSettings.scala	7
project/VersionGenerator.scala	23
project/Versions.scala	29
project/plugins.sbt	23
testkit/src/main/java/org/apache/pekko/kafka/testkit/KafkaTest.java	31
testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaJunit4Test.java	44
testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaTest.java	31
testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/KafkaContainerCluster.java	328
testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java	199
testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/SchemaRegistryContainer.java	31
testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/BaseKafkaTest.java	124
testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/KafkaJunit4Test.java	29
testkit/src/main/scala/org/apache/pekko/kafka/testkit/ConsumerResultFactory.scala	40
testkit/src/main/scala/org/apache/pekko/kafka/testkit/KafkaTestkitSettings.scala	24
testkit/src/main/scala/org/apache/pekko/kafka/testkit/KafkaTestkitTestcontainersSettings.scala	174
testkit/src/main/scala/org/apache/pekko/kafka/testkit/ProducerResultFactory.scala	45
testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/KafkaTestKit.scala	98
testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/KafkaTestKitChecks.scala	56
testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/TestFrameworkInterface.scala	19
testkit/src/main/scala/org/apache/pekko/kafka/testkit/internal/TestcontainersKafka.scala	91
testkit/src/main/scala/org/apache/pekko/kafka/testkit/javadsl/ConsumerControlFactory.scala	39
testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/ConsumerControlFactory.scala	35
testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/KafkaSpec.scala	143
testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/ScalatestKafkaSpec.scala	7
testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/TestcontainersKafkaLike.scala	26
testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/TestcontainersKafkaPerClassLike.scala	12