Hello, I have configured kafka nodes to run via supervisord and see following exceptions and eventually brokers going out of memory. i have given enough memory and process 1 event/second. kafka goes down every day
i'm wondering what configurastion is missing or need to be added Here are my cluster details: 2 brokers 1 zookeeper and 2 node apache storm INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient) ERROR Closing socket for /10.0.0.11 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:198) at sun.nio.ch.IOUtil.read(IOUtil.java:171) at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:245) at kafka.utils.Utils$.read(Utils.scala:375) 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:662) [2015-01-13 23:43:37,962] INFO Closing socket connection to /10.0.0.11. (kafka.network.Processor) Error occurred during initialization of VM Could not reserve enough space for object heap Error occurred during initialization of VM Could not reserve enough space for object heap -- Regards, Tousif +918050227279 -- Regards Tousif Khazi
