Hi All, I am using Kafka 2.10-0.8.1 and I am seeing issues while consuming messages using Simple Consumer API.
As new messages are produced, those are not retrieved by Simple consumer API and kafka server console shows the following- [2017-01-31 10:19:47,007] INFO Closing socket connection to /127.0.0.1. (kafka.network.Processor) But same messages are displayed using kafka-console-consumer.sh. Any idea what's going on here?
