Hi Debraj, Sorry for the confusion the FlinkKafkaConsumer is the old source and the overhauled one you can find here [1]. You would need to replace the FlinkKafkaConsumer with the KafkaSource to not see the message anymore.
Best Fabian [1] https://github.com/apache/flink/blob/2bd8fab01d2aba99a5f690d051e817d10d2c6f24/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java#L75
