In Kafka08Fetcher, it use Map to manage
multi-threads. But I notice in Kafka09Fetcher or Kafka010Fetcher, it's
gone. So how Kafka09Fetcher implements multi-threads read partitions from
kafka?
Thanks Eron
I have tried to read an EOF symbol and invoke FlinkKafkaConsumer's cancel
method, it doesn't work. But I invoke the method in a FlatMap operator
which is next to source operator, I guess that is the problem. I will try
your answer, thanks for your suggestion.
--
Sent from: http://a
I would like to stop FlinkKafkaConsumer consuming data from kafka manually.
But I find it won't be close when I invoke "cancel()" method. What I am
trying to do is add an EOF symbol meaning the end of my kafka data, and
when the FlatMap operator read the symbol it will invoke FlinkKafkaConsumer
"ca
