core/src/main/scala/org/apache/pekko/kafka/javadsl/Consumer.scala (2 lines): - line 188: // TODO this could use `scaladsl committableSourceWithContext` but `mapMaterializedValue` is not available, yet - line 218: // TODO this could use `scaladsl committableSourceWithContext` but `mapMaterializedValue` is not available, yet testkit/src/main/java/org/apache/pekko/kafka/testkit/internal/PekkoConnectorsKafkaContainer.java (1 line): - line 116: // TODO Only for backward compatibility, to be removed soon core/src/main/scala/org/apache/pekko/kafka/internal/ControlImplementations.scala (1 line): - line 88: // FIXME: this can't be accessed until the stream has materialized because the `def executionContext` implementation benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/CsvFormatter.scala (1 line): - line 33: // TODO: This needs to be deleted after migrating alpakka to pekko.