Thanks Fabian again for the clarification. On Thu, Jun 24, 2021 at 8:16 PM Fabian Paul <fabianp...@data-artisans.com> wrote:
> 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 > >
