This is an expected exception.
On Sat, Feb 1, 2014 at 9:29 PM, Ranjith Venkatesan <[email protected]>wrote: > Hi , > > We are evaluating kafka 0.8 for our product as a queue system. Our > architecture remains simple. Our producer (single) will send mesages to any > of the topics in broker. Thread will be running for each of the topic for > every 10 secs,which in turn consume from its corresponding topic. For each > stream we will be using ThreadPool to increase the degree of parallelism. > But when shutting down the Consumer, i am getting following exception in > broker, > > > [2014-02-01 13:06:43,240] ERROR Closing socket for /127.0.0.1 because of > error (kafka.network.Processor)java.io.IOException: Connection reset by peer > at sun.nio.ch.FileDispatcher.read0(Native Method) > at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21) > at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:233) > at sun.nio.ch.IOUtil.read(IOUtil.java:206) > at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:236) > at kafka.utils.Utils$.read(Utils.scala:395) > at > kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54) > at kafka.network.Processor.read(SocketServer.scala:347) > at kafka.network.Processor.run(SocketServer.scala:245) > at java.lang.Thread.run(Thread.java:619) > > > > > I am using Highlevel consumer, and the configuration for consumer is given > below, > > > > > Properties props = new Properties(); > props.put("zookeeper.connect", "localhost:2181"); > props.put("group.id", groupid); > props.put("zookeeper.session.timeout.ms", "12000"); > props.put("zookeeper.sync.time.ms", "200"); > // props.put("auto.commit.interval.ms", "1000"); > props.put("auto.commit.enable", "false"); > //props.put("consumer.timeout.ms", "10000"); > props.put("auto.offset.reset", "smallest"); > props.put("socket.timeout.ms", "10000"); > > > > Am i missing something ? Or this is a expected exception??? > > > PS: We are using Java Client > > > Thanks in advance > > > > > Ranjith Venkatesan > > >
