Created 10-03-2016 06:09 AM
Hi All,
I am using java producer to produce messages and Scala Consumer to consume messages from producer, with this i am able to produce correct no.of messages from hdfs and unable to consume all the messages , Here is my java producer and consumer code please find attached.scalaconsumer.txt
please let me know what is the reason.
Thanks in advance.
Created 10-05-2016 06:16 PM
Consumer will count the messages "Produced" during the same timeframe. Are the StartDateTime and EndDateTime identical for Producer and Consumer counts? How do you guarantee that?