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
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