title: Camel-Kafka Zookeeper Exception
body: <p>I am starting a camel-kafka consumer, where it takes all the data from topic and moves to a hashmap. The Jar version for camel-Kafka is 2.18.1</p>
  
  <p>The cxfbeans.xml file is as follows:</p>
  
  <p></p>
  
  <pre><code>    &lt;route id="Test1" streamCache="true"&gt;
          &lt;from uri="file:C:/data" /&gt;
          &lt;split streaming="true"&gt;
              &lt;tokenize token="\n" /&gt;
              &lt;to uri="bean:proc1" /&gt;
              &lt;to
                  uri="kafka:localhost:9092?topic=Checking&amp;amp;zookeeperHost=localhost&amp;amp;zookeeperPort=2181&amp;amp;serializerClass=kafka.serializer.StringEncoder" /&gt;
          &lt;/split&gt;
      &lt;/route&gt;
  </code></pre>
  
  <p>If i deploy the war i am getting the below exception:</p>
  
  <p><strong>Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: kafka://localhost:9092?serializerClass=kafka.serializer.StringEncoder&amp;topic=Checking&amp;zookeeperHost=localhost&amp;zookeeperPort=2181 due to: There are 2 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{zookeeperHost=localhost, zookeeperPort=2181}]</strong></p>
  
  <p>I tried by removing teh ports and host of zookeeper ,it got deployed,but consumer is not consuming and placing in the processor.</p>
  
  <p>Can anyone help me to resolve this issue. I degraded the version to, but i need to specify a de-serializer class in the to tag.</p>