Path	Lines of Code
java-tests/src/test/resources/logback-test.xml	38
java-tests/src/test/scala/org/apache/pekko/kafka/tests/javadsl/LogCapturingExtension.scala	21
java-tests/src/test/scala/org/apache/pekko/kafka/tests/javadsl/LogCapturingJunit4.scala	33
tests/src/it/resources/logback-test.xml	39
tests/src/it/scala/org/apache/pekko/kafka/IntegrationTests.scala	31
tests/src/it/scala/org/apache/pekko/kafka/PartitionedSourceFailoverSpec.scala	81
tests/src/it/scala/org/apache/pekko/kafka/PlainSourceFailoverSpec.scala	70
tests/src/it/scala/org/apache/pekko/kafka/TransactionsPartitionedSourceSpec.scala	104
tests/src/it/scala/org/apache/pekko/kafka/TransactionsSourceSpec.scala	160
tests/src/main/proto/order.proto	14
tests/src/main/scala/org/apache/pekko/kafka/KafkaPorts.scala	5
tests/src/test/resources/logback-test.xml	38
tests/src/test/scala/org/apache/pekko/kafka/ConfigSettingsSpec.scala	28
tests/src/test/scala/org/apache/pekko/kafka/ConsumerSettingsSpec.scala	231
tests/src/test/scala/org/apache/pekko/kafka/ProducerSettingsSpec.scala	218
tests/src/test/scala/org/apache/pekko/kafka/Repeated.scala	19
tests/src/test/scala/org/apache/pekko/kafka/TransactionsOps.scala	206
tests/src/test/scala/org/apache/pekko/kafka/internal/CommitCollectorStageSpec.scala	355
tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala	567
tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingWithMockSpec.scala	409
tests/src/test/scala/org/apache/pekko/kafka/internal/ConnectionCheckerSpec.scala	64
tests/src/test/scala/org/apache/pekko/kafka/internal/ConsumerDummy.scala	81
tests/src/test/scala/org/apache/pekko/kafka/internal/ConsumerMock.scala	179
tests/src/test/scala/org/apache/pekko/kafka/internal/ConsumerProgressTrackingSpec.scala	154
tests/src/test/scala/org/apache/pekko/kafka/internal/ConsumerResetProtectionSpec.scala	128
tests/src/test/scala/org/apache/pekko/kafka/internal/ConsumerSpec.scala	260
tests/src/test/scala/org/apache/pekko/kafka/internal/EnhancedConfigSpec.scala	20
tests/src/test/scala/org/apache/pekko/kafka/internal/OffsetAggregationSpec.scala	38
tests/src/test/scala/org/apache/pekko/kafka/internal/PartitionedSourceSpec.scala	595
tests/src/test/scala/org/apache/pekko/kafka/internal/ProducerSpec.scala	544
tests/src/test/scala/org/apache/pekko/kafka/internal/SubscriptionsSpec.scala	41
tests/src/test/scala/org/apache/pekko/kafka/javadsl/ControlSpec.scala	75
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/CommittableSinkSpec.scala	80
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/CommittingSpec.scala	442
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/ConnectionCheckerSpec.scala	63
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/ControlSpec.scala	61
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/IntegrationSpec.scala	279
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/MetadataClientSpec.scala	106
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/MisconfiguredConsumerSpec.scala	49
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/MisconfiguredProducerSpec.scala	35
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/MultiConsumerSpec.scala	92
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/PartitionedSourcesSpec.scala	491
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/RebalanceExtSpec.scala	252
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/RebalanceSpec.scala	212
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/ReconnectSpec.scala	91
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/RetentionPeriodSpec.scala	77
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/SpecBase.scala	33
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/TimestampSpec.scala	71
tests/src/test/scala/org/apache/pekko/kafka/scaladsl/TransactionsSpec.scala	402
tests/src/test/scala/org/apache/pekko/kafka/tests/CapturingAppender.scala	40
tests/src/test/scala/org/apache/pekko/kafka/tests/LogbackUtil.scala	29
tests/src/test/scala/org/apache/pekko/kafka/tests/scaladsl/LogCapturing.scala	35