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
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.
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
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
> 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.
:
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.
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.
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.