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.org/flink/flink-docs-master/docs/connectors/table/kafka/#available-metadata
Weihua Hu <huweihua....@gmail.com> 于2022年5月19日周四 21:42写道：
> Hi Harshit,
> FlinkKafkaConsumer does not support consuming a particular partition of a
> topic.
>
> Best,
> Weihua
>
> 2022年5月18日 下午5:02，harshit.varsh...@iktara.ai <harshit.varsh...@iktara.ai>
> 写道：
>
> particular
>
>
>
