flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaShuffleFetcher.java (2 lines):
	- line 110: // TODO: Do we need to check the end of stream if reaching the end watermark
	- line 111: // TODO: Currently, if one of the partition sends an end-of-stream signal the fetcher


flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaConsumerThread.java (1 line):
	- line 189: // TODO this metric is kept for compatibility purposes; should remove in the


flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffle.java (1 line):
	- line 339: // TODO: consider situations where numberOfPartitions != consumerParallelism


flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java (1 line):
	- line 71: // TODO: remove the workaround after Kafka dependency is bumped to 2.3.0+


flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1 line):
	- line 1410: // TODO: somehow merge metrics from all active producers?


flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java (1 line):
	- line 333: // TODO: Handle removed partitions.