KafkaConsumerBase

2017-08-02 Thread aitozi
Hi, i have a question that , when we use KafkaConsumerBase, we will have to fetch data from different partition in different parllel thread like the method shown in KafkaConsumerBase.java (version 1.2.0) protected static List assignPartitions( List

About KafkaConsumerBase

2017-08-01 Thread aitozi
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/About-KafkaConsumerBase-tp14601.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: KafkaConsumerBase

2017-08-02 Thread Tzu-Li (Gordon) Tai
subtask should subscribe to. Cheers, Gordon On 2 August 2017 at 9:52:03 PM, aitozi (gjying1...@gmail.com) wrote: Hi, i have a question that , when we use KafkaConsumerBase, we will have to fetch data from different partition in different parllel thread like the method shown in

Re: KafkaConsumerBase

2017-08-02 Thread aitozi
artitions for each local subtask, using the `assignTopicPartitions` method" Thanks aitozi -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/KafkaConsumerBase-tp14636p14642.html Sent from the Apache Flink User Mailing List archive. maili

Re: About KafkaConsumerBase

2017-08-01 Thread Piotr Nowojski
> thanks > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/About-KafkaConsumerBase-tp14601.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.

Re: About KafkaConsumerBase

2017-08-01 Thread aitozi
: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/About-KafkaConsumerBase-tp14601p14619.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: About KafkaConsumerBase

2017-08-01 Thread Tzu-Li (Gordon) Tai
context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/About-KafkaConsumerBase-tp14601p14619.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: About KafkaConsumerBase

2017-08-02 Thread aitozi
Hi， thanks，you explained clearly! -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/About-KafkaConsumerBase-tp14601p14621.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.