at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
        at sun.nio.ch.IOUtil.read(IOUtil.java:197)
        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379)
        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:745)
[2014-08-28 12:53:26,339] ERROR Closing socket for /192.168.8.250 because of error (kafka.network.Processor)
java.io.IOException: Connection reset by peer
        at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
        at sun.nio.ch.IOUtil.read(IOUtil.java:197)
        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379)
        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:745)
{"apikey":"37572631-053a-4a62-a067-a14f9c98396d","tenant_id":"3fee8132b2444b44b5033c5c4d07b124","message":"CTCKafka-log json message 2014-08-28 13:05:32","@timestamp":"2014-08-28T13:05:32.000Z"}
CTCKafka-log message not in json format 2014-08-28 13:05:33
{"message":"redbutton","@version":"1","@timestamp":"2014-08-28T13:09:13.044Z","host":"127.0.0.1","tenant_id":"3fee8132b2444b44b5033c5c4d07b124","apikey":"37572631-053a-4a62-a067-a14f9c98396d"}
[2014-08-28 13:09:59,599] ERROR Closing socket for /192.168.8.250 because of error (kafka.network.Processor)
java.io.IOException: Connection reset by peer
        at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
        at sun.nio.ch.IOUtil.read(IOUtil.java:197)
        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379)
        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:745)
@ # % % ^ & * (
{"apikey":"37572631-053a-4a62-a067-a14f9c98396d","tenant_id":"3fee8132b2444b44b5033c5c4d07b124","message":"message for logTopic","alt_message":"alternative message","@timestamp":"2014-06-11T18:56:19.399Z"}