You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by yuess_coder <64...@qq.com> on 2019/03/20 11:38:03 UTC

回复： FlinkKafkaConsumer 为什么不支持制定分区消费

这样就行了partitionOffset 里面指定分区和offset
FlinkKafkaConsumer011 consumer = ...
 Map<KafkaTopicPartition, Long> partitionOffset = ... 
consumer.setStartFromSpecificOffsets(partitionOffset);






------------------ 原始邮件 ------------------
发件人: "Biao Liu"<mm...@gmail.com>;
发送时间: 2019年3月20日(星期三) 下午3:24
收件人: "user-zh"<us...@flink.apache.org>;

主题: Re: FlinkKafkaConsumer 为什么不支持制定分区消费



Hi,
构造函数中的 topics, topicPattern 不能满足你的需求吗？

yuqingshui <yu...@qq.com> 于2019年3月18日周一 下午10:33写道：

> 如题：FlinkKafkaConsumer 为什么不支持制定分区消费？