Hi All,
Now I am writting a test code for reading messages from topic of
Kafka,I used the ReliableKafkaReceiver,
However,when i created the KafkaInputDStream and store all received message in
an foreachRDD action,I don't know when all the messages have been consumed
comletely?
in other words, is there any API or methods I can use to check if all the
messages are consumed?Anyone can help me? Any suggestions are welcome! Best regards, cast cas...@163.com
