Hi,
If you use SQL API, you can specify the partition in the DDL[1] and filter
out the record that you don't need.
```
CREATE TABLE KafkaSource (
...
`partition` METADATA
) WITH (
...
);
SELECT * FROM KafkaSource
WHERE partition = 1;
```
Best,
Shengkai
[1]
https://nightlies.apache.o
Hi Harshit,
FlinkKafkaConsumer does not support consuming a particular partition of a topic.
Best,
Weihua
> 2022年5月18日 下午5:02，harshit.varsh...@iktara.ai 写道：
>
> particular
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 . I
