Re: Java WebServer based on high level consumer not consuming messages, Socket Closure issue

something related to Garbage Collection in my webserver? If so, how to investigate? On Mon, Apr 11, 2016 at 12:45 PM, NISHANT BULCHANDANI < nbulchand...@gmail.com> wrote: > Hi Everyone, > > We are using the Kafka High level consumer in our web server to consume > messages. > > Some

Java WebServer based on high level consumer not consuming messages, Socket Closure issue

Hi Everyone, We are using the Kafka High level consumer in our web server to consume messages. Sometimes, when i am running the message producer, Kafka & the webserver all 3 on my localhost ; the webserver does not recieve any messages & i see the below logs in *kafka.log* log file : [2016-04-11

Zookeeper sessions keep expiring…no heartbeats?

Hi, We are using Kafka high level consumer , and we are able to successfully consume messages but the zookeeper connections keep expiring and reestablishing. I am wondering why are there no heartbeats to keep the connections alive: Kafka Consumer Logs [localhost-startStop-1

Producer keeps trying to reconnect if kafka is down & fills up log file

Hi All, We are using Kafka Producer in our web application. Things are fine when it is up, but in case it goes down, the log is over populated with the following error : 2016-03-07 12:37:42,813 WARN [kafka-producer-network-thread | producer-1] [Selector] [line : 276 ] - Error in I/O with /10.4

Enforce Unique consumer group id in Kafka

We are making a Kafka Queue into which messages are being published from source system. Now multiple consumers can connect to this queue to read messages. While doing this the consumers have to specify a groupId based on which the messages are distributed , if two apps have the same groupId both o