flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/StoppableKafkaEnumContextProxy.java (1 line):
	- line 208: * <p>TODO: Attach Flink JIRA ticket -- discuss with upstream how to cancel scheduled tasks


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