Re: Consumer keeps looking connection

2014-11-03 Thread Jun Rao
It seems that the consumer can't connect to the broker for some reason. Any other error on the broker? Any issue with the network? Thanks, Jun On Sat, Nov 1, 2014 at 9:46 PM, Chen Wang chen.apache.s...@gmail.com wrote: Hello Folks, I am using Highlevel consumer, and it seems to drop

Re: Consumer keeps looking connection

2014-11-02 Thread Chen Wang
When I check the server log, it also flushes with exception: [2014-11-02 10:00:32,284] ERROR Closing socket for /10.93.80.119 because of error (kafka.network.Processor) java.io.IOException: Broken pipe at sun.nio.ch.FileChannelImpl.transferTo0(Native Method) at

Consumer keeps looking connection

2014-11-01 Thread Chen Wang
Hello Folks, I am using Highlevel consumer, and it seems to drop connections intermittently: 2014-11-01 13:34:40 SimpleConsumer [INFO] Reconnect due to socket error: Received -1 when reading from channel, socket has likely been closed. 2014-11-01 13:34:40 ConsumerFetcherThread [WARN]