Path Lines of Code kafka/src/main/scala/org/apache/pekko/projection/kafka/KafkaOffsets.scala 25 kafka/src/main/scala/org/apache/pekko/projection/kafka/internal/KafkaSourceProviderImpl.scala 132 kafka/src/main/scala/org/apache/pekko/projection/kafka/internal/KafkaSourceProviderSettings.scala 19 kafka/src/main/scala/org/apache/pekko/projection/kafka/internal/MetadataClientAdapter.scala 42 kafka/src/main/scala/org/apache/pekko/projection/kafka/javadsl/KafkaSourceProvider.scala 27 kafka/src/main/scala/org/apache/pekko/projection/kafka/scaladsl/KafkaSourceProvider.scala 25