Description
I've compared the SimpleMovingAvgZkConsumer.java code with what was presented in the Kafka video from O'Reilly, and have successfully compiled it, but it just does not want to calculate the moving average and present it to the screen.
I've tried using both the SimpleCounter.java and the kafka-console-producer.sh to produce the numbers that SimpleMovingAvgZkConsumer.java needs, but it just remains silent until the timeout is reached and then it exits.
I'm thinking that I'm getting some kind of mismatch between the Old and New producer types, but I'm too much of a newb to be able to figure it out.
I will add that the kafka-console-consumer.sh works fine reading from both SimpleCounter.java and kafka-console-producer.sh, so it would appear that my Kafka 2 node cluster is working properly
Any sugestions?