title: ERROR Closing socket for /127.0.0.1 because of error (kafka.network.Processor)
body: <p>I'm new to apache camel and apache kafka and doing a small POC for my project. I am getting following issue error log when trying to read from kafka using Camel-kafka component.</p>
  
  <pre><code>[2016-01-20 08:47:10,979] INFO Closing socket connection to /127.0.0.1. (kafka.network.Processor)
  [2016-01-20 08:47:44,643] INFO Closing socket connection to /127.0.0.1. (kafka.network.Processor)
  [2016-01-20 08:47:54,545] ERROR Closing socket for /127.0.0.1 because of error (kafka.network.Processor)
  java.io.IOException: Broken pipe
      at sun.nio.ch.FileDispatcherImpl.write0(Native Method)
      at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47)
      at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93)
      at sun.nio.ch.IOUtil.write(IOUtil.java:65)
      at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:470)
      at kafka.api.TopicDataSend.writeTo(FetchResponse.scala:123)
      at kafka.network.MultiSend.writeTo(Transmission.scala:101)
      at kafka.api.FetchResponseSend.writeTo(FetchResponse.scala:231)
      at kafka.network.Processor.write(SocketServer.scala:472)
      at kafka.network.Processor.run(SocketServer.scala:342)
      at java.lang.Thread.run(Thread.java:745)
  </code></pre>
  
  <p>My java code is as follows:</p>
  
  <pre><code>public class Main {
  public static void main(String[] args) throws Exception {
  
      CamelContext context = new DefaultCamelContext();
      context.addRoutes(new RouteBuilder() {
          public void configure() {
              from("kafka:127.0.0.1:9092?topic=TEST&amp;zookeeperHost=localhost&amp;zookeeperPort=2181&amp;groupId=group1")
                      /*.marshal(xmlJsonFormat)*/
              .process(new XmlToJson())
                      /*.to("kafka:localhost:9092?topic=TestJson&amp;zookeeperHost=localhost&amp;zookeeperPort=2181&amp;groupId=group1");*/
              .to("file:/Users/himanshu/Desktop/TransCamelFuse/test.txt");
          }
      });
      context.start();
      Thread.sleep(10000);
      context.stop();
  }
  </code></pre>
  
  <p>}</p>
  
  <p>I've put some txt from kafka producer console tool and trying to read using camel component of kafka. </p>