Path	Lines of Code
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	221
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	82