Dear Team,

I am new to pyflink and request for your support in issue I am facing with
Pyflink. I am using Pyflink version 1.14.4.

 

My Question is : I am using Distributed Kafka System ,Pyflink and wants to
collect data From a particular Partition  of a Topic using Pyflink
FlinkKafkaConsumer . Is this functionality is present in pyflink then please
give me answer how to do that.

 

Thanks and Regards,

Harshit

Reply via email to