Re: Unable to read records from kafka

2023-10-02 Thread joshua perez
Hi Team, you can ignore this thread. I was able to resolve this. J. On Mon, Oct 2, 2023 at 8:40 PM joshua perez wrote: > Hi team, > > I am trying to read the records from the Kafka topic and below is my very > basic code as of now > > from pyflink.datastream.connectors.kafka import

Unable to read records from kafka

2023-10-02 Thread joshua perez
Hi team, I am trying to read the records from the Kafka topic and below is my very basic code as of now from pyflink.datastream.connectors.kafka import FlinkKafkaConsumer from pyflink.datastream.stream_execution_environment import StreamExecutionEnvironment, RuntimeExecutionMode from