You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by bu...@apache.org on 2016/03/21 20:18:42 UTC

svn commit: r983361 - in /websites/production/camel/content: cache/main.pageCache kafka.html

Author: buildbot
Date: Mon Mar 21 19:18:41 2016
New Revision: 983361

Log:
Production update by buildbot for camel

Modified:
    websites/production/camel/content/cache/main.pageCache
    websites/production/camel/content/kafka.html

Modified: websites/production/camel/content/cache/main.pageCache
==============================================================================
Binary files - no diff available.

Modified: websites/production/camel/content/kafka.html
==============================================================================
--- websites/production/camel/content/kafka.html (original)
+++ websites/production/camel/content/kafka.html Mon Mar 21 19:18:41 2016
@@ -93,7 +93,7 @@
     <!-- use the same version as your Camel core version -->
 </dependency>
 ]]></script>
-</div></div><h4 id="Kafka-Camel2.17ornewer">Camel 2.17 or newer</h4><p>Scala is not longer used, as we use the kafka java client.</p><h4 id="Kafka-Camel2.16orolder">Camel 2.16 or older</h4><p>And then the Scala libraries of choice. camel-kafka does not include that dependency, but assume its provided. For example to use Scala 2.10.4 add:</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
+</div></div><h4 id="Kafka-Camel2.17ornewer">Camel 2.17 or newer</h4><p>Scala is no longer used, as we use the kafka java client.</p><h4 id="Kafka-Camel2.16orolder">Camel 2.16 or older</h4><p>And then the Scala libraries of choice. camel-kafka does not include that dependency, but assume its provided. For example to use Scala 2.10.4 add:</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
 <script class="brush: xml; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[    &lt;dependency&gt;
       &lt;groupId&gt;org.scala-lang&lt;/groupId&gt;
       &lt;artifactId&gt;scala-library&lt;/artifactId&gt;
@@ -102,10 +102,48 @@
 </div></div><h3 id="Kafka-URIformat">URI format</h3><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
 <script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[kafka:server:port[?options]
 ]]></script>
-</div></div><p>&#160;</p><h3 id="Kafka-Options(Camel2.16orolder)">Options (Camel 2.16 or older)</h3><div class="confluenceTableSmall"><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh"><p>Property</p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Default</p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>zookeeperHost</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>&#160;</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The zookeeper host to use</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>zookeeperPort</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>2181</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The zookeeper port to use</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">zookeeperConnect</td><td colspan="1" rowspan="1" class="conf
 luenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd"><strong>Camel 2.13.3/2.14.1:</strong> If in use, then zookeeperHost/zookeeperPort is not used.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>topic</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>&#160;</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The topic to use</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>groupId</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>partitioner</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>consumerStreams</p></td><td colspan="1" rowspan="1" class="confluenceTd">10</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><
 td colspan="1" rowspan="1" class="confluenceTd"><p>clientId</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>zookeeperSessionTimeoutMs</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>zookeeperConnectionTimeoutMs</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>zookeeperSyncTimeMs</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p><span style="color: rgb(51,51,51);">consumersCount</span></p></td><td colspan="1" rowspan="1" class="confl
 uenceTd"><p><span style="color: rgb(51,51,51);">1</span></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p><strong>Camel 2.15.0:</strong> The number of consumers that connect to kafka server</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p><span style="color: rgb(51,51,51);">batchSize</span></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p><span style="color: rgb(51,51,51);">100</span></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p><strong>Camel 2.15.0: </strong>The batchSize that the BatchingConsumerTask processes once.<strong><br clear="none"></strong></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p><span style="color: rgb(51,51,51);">barrierAwaitTimeoutMs</span></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p><span style="color: rgb(51,51,51);">10000</span></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p><strong>Camel 2.15.0: </strong>If the BatchingConsumerTask processes exchange e
 xceed the batchSize, it will wait for <span style="color: rgb(51,51,51);">barrierAwaitTimeoutMs</span>.<strong><br clear="none"></strong></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">bridgeEndpoint</td><td colspan="1" rowspan="1" class="confluenceTd">false</td><td colspan="1" rowspan="1" class="confluenceTd">Camel 2.16.0: If the bridgeEndpoint is true, the producer will ignore the topic header setting of the message.</td></tr></tbody></table></div></div><p>You can append query options to the URI in the following format, <code>?option=value&amp;option=value&amp;...</code></p><h3 id="Kafka-ProducerOptions(Camel2.16orolder)">Producer Options&#160;(Camel 2.16 or older)</h3><div class="confluenceTableSmall"><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh"><p>Property</p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Default</p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Descripti
 on</p></th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>producerType</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>sync (Taken from native KafkaProducer class)</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>sync - send message/batch immediately, and wait until response is received</p><p>async - queue the message/batch to send. There is a thread per broker (Kafka node) which polls from this queue upon <span>queueBufferingMaxMs or <span>batchNumMessages</span></span></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">compressionCodec</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">compressedTopics</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">messageSendMaxRetrie
 s</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">retryBackoffMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">topicMetadataRefreshIntervalMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">sendBufferBytes</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">requestRequiredAcks</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">req
 uestTimeoutMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">queueBufferingMaxMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">queueBufferingMaxMessages</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">queueEnqueueTimeoutMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">batchNumMessages</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="co
 nfluenceTd">serializerClass</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">keySerializerClass</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr></tbody></table></div></div><h3 id="Kafka-ConsumerOptions(Camel2.16orolder)">Consumer Options&#160;(Camel 2.16 or older)</h3><div class="confluenceTableSmall"><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh"><p>Property</p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Default</p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>consumerId</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>&#160;</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</t
 d></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">socketTimeoutMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">socketReceiveBufferBytes</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">fetchMessageMaxBytes</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">autoCommitEnable</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">autoCommitIntervalMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluence
 Td">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">queuedMaxMessages</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">rebalanceMaxRetries</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">fetchMinBytes</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">fetchWaitMaxMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">rebalanceBackoffMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceT
 d">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">refreshLeaderBackoffMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">autoOffsetReset</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">consumerTimeoutMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr></tbody></table></div></div><h3 id="Kafka-Options(Camel2.17ornewer)">Options (Camel 2.17 or newer)</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Property</th><th colspan="1" rowspan="1" class="confluenceTh">Default</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colsp
 an="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">topic</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">Topic to use</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">groupId</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">consumerStreams</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">10</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">clientId</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span 
 class="s1">consumersCount</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">1</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">The number of consumers that connect to kafka server</span></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">batchSize</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">100</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">Commit Size if auto commit is false</span></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">bridgeEndpoint</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">false</td><td colspan="1" rowspan="1" class="confluenceTd"><span>Camel 2.16.0: If the bridgeEndpoint is true, the producer will ignore the topic header setting of the message.</span></td></tr></tbody></table></div><p>&#160;</p><h3 id="Kafka-ProducerOptions(Camel2.17ornewer)">Produce
 r Options&#160;(Camel 2.17 or newer)</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Property</th><th colspan="1" rowspan="1" class="confluenceTh">Default &amp; Description Reference</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>keyDeserializer</p></td><td colspan="1" rowspan="46" class="confluenceTd"><p class="p1"><span class="s1"><span class="nolink">http://kafka.apache.org/documentation.html#producerconfigs</span></span></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>keyDeserializer</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>requestRequiredAcks&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>bufferMemorySize&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>compressionCodec&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>retries&#160;</p></td></tr><tr><td colspan="1"
  rowspan="1" class="confluenceTd"><p>sslKeyPassword</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeystoreLocation</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeystorePassword</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTruststoreLocation</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTruststorePassword</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>producerBatchSize&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>clientId</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>connectionMaxIdleMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>lingerMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>maxBlockMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>maxRequestSize&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="conflue
 nceTd"><p>partitioner&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>receiveBufferBytes&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>requestTimeoutMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>saslKerberosServiceName</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>securityProtocol</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sendBufferBytes&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslEnabledProtocols&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeystoreType&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslProtocol&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslProvider</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTruststoreType</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>tim
 eoutMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>blockOnBufferFull&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>maxInFlightRequest&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metadataFetchTimeoutMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metadataMaxAgeMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metricReporters</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>noOfMetricsSample&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metricsSampleWindowMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>reconnectBackoffMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>retryBackoffMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosInitCmd&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confl
 uenceTd"><p>kerberosBeforeReloginMinTime&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosRenewJitter&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosRenewWindowFactor&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslCipherSuites</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslEndpointAlgorithm</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeymanagerAlgorithm&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTrustmanagerAlgorithm&#160;</p></td></tr></tbody></table></div><h3 id="Kafka-ConsumerOptions(Camel2.17ornewer)">Consumer Options&#160;(Camel 2.17 or newer)</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Property</th><th colspan="1" rowspan="1" class="confluenceTh">Default &amp; Description Reference</th></tr><tr><td colspan="1" rowspan
 ="1" class="confluenceTd"><p>bootstrapServers</p></td><td colspan="1" rowspan="45" class="confluenceTd"><p class="p1"><span class="s1"><span class="nolink">http://kafka.apache.org/documentation.html#newconsumerconfigs</span></span></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>keyDeserializer</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>valueDeserializer</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>fetchMinBytes&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>groupId</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>heartbeatIntervalMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>maxPartitionFetchBytes&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sessionTimeoutMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeyPassword</p></td></tr><tr><td colspan="1" rowspan="1" class="conflu
 enceTd"><p>sslKeystoreLocation</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeystorePassword</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTruststoreLocation</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTruststorePassword</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>autoOffsetReset&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>connectionMaxIdleMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>autoCommitEnable&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>partitionAssignor&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>receiveBufferBytes&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>consumerRequestTimeoutMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>saslKerberosServiceName</p></td></tr><tr><td colspan="1" rows
 pan="1" class="confluenceTd"><p>securityProtocol</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sendBufferBytes&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslEnabledProtocols&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeystoreType&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslProtocol&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslProvider</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTruststoreType</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>autoCommitIntervalMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>checkCrcs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>clientId</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>fetchWaitMaxMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><
 p>metadataMaxAgeMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metricReporters</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>noOfMetricsSample&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metricsSampleWindowMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>reconnectBackoffMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>retryBackoffMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosInitCmd&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosBeforeReloginMinTime&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosRenewJitter&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosRenewWindowFactor&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslCipherSuites</p></td></tr><tr><td colspan="1" rows
 pan="1" class="confluenceTd"><p>sslEndpointAlgorithm</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeymanagerAlgorithm&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTrustmanagerAlgorithm&#160;</p></td></tr></tbody></table></div><p>&#160;</p><h3 id="Kafka-Samples">Samples</h3><h4 id="Kafka-Camel2.16orolder.1">Camel 2.16 or older</h4><p>Consuming messages:</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
+</div></div><p>&#160;</p><h3 id="Kafka-Options(Camel2.16orolder)">Options (Camel 2.16 or older)</h3><div class="confluenceTableSmall"><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh"><p>Property</p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Default</p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>zookeeperHost</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>&#160;</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The zookeeper host to use</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>zookeeperPort</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>2181</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The zookeeper port to use</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">zookeeperConnect</td><td colspan="1" rowspan="1" class="conf
 luenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd"><strong>Camel 2.13.3/2.14.1:</strong> If in use, then zookeeperHost/zookeeperPort is not used.</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>topic</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>&#160;</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>The topic to use</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>groupId</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>partitioner</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>consumerStreams</p></td><td colspan="1" rowspan="1" class="confluenceTd">10</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><
 td colspan="1" rowspan="1" class="confluenceTd"><p>clientId</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>zookeeperSessionTimeoutMs</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>zookeeperConnectionTimeoutMs</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>zookeeperSyncTimeMs</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p><span style="color: rgb(51,51,51);">consumersCount</span></p></td><td colspan="1" rowspan="1" class="confl
 uenceTd"><p><span style="color: rgb(51,51,51);">1</span></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p><strong>Camel 2.15.0:</strong> The number of consumers that connect to kafka server</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p><span style="color: rgb(51,51,51);">batchSize</span></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p><span style="color: rgb(51,51,51);">100</span></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p><strong>Camel 2.15.0: </strong>The batchSize that the BatchingConsumerTask processes once.<strong><br clear="none"></strong></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p><span style="color: rgb(51,51,51);">barrierAwaitTimeoutMs</span></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p><span style="color: rgb(51,51,51);">10000</span></p></td><td colspan="1" rowspan="1" class="confluenceTd"><p><strong>Camel 2.15.0: </strong>If the BatchingConsumerTask processes exchange e
 xceed the batchSize, it will wait for <span style="color: rgb(51,51,51);">barrierAwaitTimeoutMs</span>.<strong><br clear="none"></strong></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">bridgeEndpoint</td><td colspan="1" rowspan="1" class="confluenceTd">false</td><td colspan="1" rowspan="1" class="confluenceTd">Camel 2.16.0: If the bridgeEndpoint is true, the producer will ignore the topic header setting of the message.</td></tr></tbody></table></div></div><p>You can append query options to the URI in the following format, <code>?option=value&amp;option=value&amp;...</code></p><h3 id="Kafka-ProducerOptions(Camel2.16orolder)">Producer Options&#160;(Camel 2.16 or older)</h3><div class="confluenceTableSmall"><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh"><p>Property</p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Default</p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Descripti
 on</p></th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>producerType</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>sync (Taken from native KafkaProducer class)</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>sync - send message/batch immediately, and wait until response is received</p><p>async - queue the message/batch to send. There is a thread per broker (Kafka node) which polls from this queue upon <span>queueBufferingMaxMs or <span>batchNumMessages</span></span></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">compressionCodec</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">compressedTopics</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">messageSendMaxRetrie
 s</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">retryBackoffMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">topicMetadataRefreshIntervalMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">sendBufferBytes</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">requestRequiredAcks</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">req
 uestTimeoutMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">queueBufferingMaxMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">queueBufferingMaxMessages</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">queueEnqueueTimeoutMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">batchNumMessages</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="co
 nfluenceTd">serializerClass</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">keySerializerClass</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr></tbody></table></div></div><h3 id="Kafka-ConsumerOptions(Camel2.16orolder)">Consumer Options&#160;(Camel 2.16 or older)</h3><div class="confluenceTableSmall"><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh"><p>Property</p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Default</p></th><th colspan="1" rowspan="1" class="confluenceTh"><p>Description</p></th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>consumerId</p></td><td colspan="1" rowspan="1" class="confluenceTd"><p>&#160;</p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</t
 d></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">socketTimeoutMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">socketReceiveBufferBytes</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">fetchMessageMaxBytes</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">autoCommitEnable</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">autoCommitIntervalMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluence
 Td">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">queuedMaxMessages</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">rebalanceMaxRetries</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">fetchMinBytes</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">fetchWaitMaxMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">rebalanceBackoffMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceT
 d">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">refreshLeaderBackoffMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">autoOffsetReset</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd">consumerTimeoutMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr></tbody></table></div></div><h3 id="Kafka-Options(Camel2.17ornewer)">Options (Camel 2.17 or newer)</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Property</th><th colspan="1" rowspan="1" class="confluenceTh">Default</th><th colspan="1" rowspan="1" class="confluenceTh">Description</th></tr><tr><td colsp
 an="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">topic</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">Topic to use</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">groupId</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">consumerStreams</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">10</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">clientId</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span 
 class="s1">consumersCount</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">1</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">The number of consumers that connect to kafka server</span></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">batchSize</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">100</td><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">Commit Size if auto commit is false</span></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p class="p1"><span class="s1">bridgeEndpoint</span></p></td><td colspan="1" rowspan="1" class="confluenceTd">false</td><td colspan="1" rowspan="1" class="confluenceTd"><span>Camel 2.16.0: If the bridgeEndpoint is true, the producer will ignore the topic header setting of the message.</span></td></tr></tbody></table></div><p>&#160;</p><h3 id="Kafka-ProducerOptions(Camel2.17ornewer)">Produce
 r Options&#160;(Camel 2.17 or newer)</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Property</th><th colspan="1" rowspan="1" class="confluenceTh">Default &amp; Description Reference</th></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>keyDeserializer</p></td><td colspan="1" rowspan="46" class="confluenceTd"><p class="p1"><span class="s1"><span class="nolink">http://kafka.apache.org/documentation.html#producerconfigs</span></span></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>keyDeserializer</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>requestRequiredAcks&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>bufferMemorySize&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>compressionCodec&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>retries&#160;</p></td></tr><tr><td colspan="1"
  rowspan="1" class="confluenceTd"><p>sslKeyPassword</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeystoreLocation</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeystorePassword</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTruststoreLocation</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTruststorePassword</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>producerBatchSize&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>clientId</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>connectionMaxIdleMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>lingerMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>maxBlockMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>maxRequestSize&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="conflue
 nceTd"><p>partitioner&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>receiveBufferBytes&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>requestTimeoutMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>saslKerberosServiceName</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>securityProtocol</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sendBufferBytes&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslEnabledProtocols&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeystoreType&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslProtocol&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslProvider</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTruststoreType</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>tim
 eoutMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>blockOnBufferFull&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>maxInFlightRequest&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metadataFetchTimeoutMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metadataMaxAgeMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metricReporters</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>noOfMetricsSample&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metricsSampleWindowMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>reconnectBackoffMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>retryBackoffMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosInitCmd&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confl
 uenceTd"><p>kerberosBeforeReloginMinTime&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosRenewJitter&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosRenewWindowFactor&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslCipherSuites</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslEndpointAlgorithm</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeymanagerAlgorithm&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTrustmanagerAlgorithm&#160;</p></td></tr></tbody></table></div><h3 id="Kafka-ConsumerOptions(Camel2.17ornewer)">Consumer Options&#160;(Camel 2.17 or newer)</h3><div class="table-wrap"><table class="confluenceTable"><tbody><tr><th colspan="1" rowspan="1" class="confluenceTh">Property</th><th colspan="1" rowspan="1" class="confluenceTh">Default &amp; Description Reference</th></tr><tr><td colspan="1" rowspan
 ="1" class="confluenceTd"><p>&#160;</p></td><td colspan="1" rowspan="45" class="confluenceTd"><p class="p1"><span class="s1"><span class="nolink">http://kafka.apache.org/documentation.html#newconsumerconfigs</span></span></p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>keyDeserializer</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>valueDeserializer</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>fetchMinBytes&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>groupId</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>heartbeatIntervalMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>maxPartitionFetchBytes&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sessionTimeoutMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeyPassword</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p
 >sslKeystoreLocation</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeystorePassword</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTruststoreLocation</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTruststorePassword</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>autoOffsetReset&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>connectionMaxIdleMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>autoCommitEnable&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>partitionAssignor&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>receiveBufferBytes&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>consumerRequestTimeoutMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>saslKerberosServiceName</p></td></tr><tr><td colspan="1" rowspan="1" cl
 ass="confluenceTd"><p>securityProtocol</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sendBufferBytes&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslEnabledProtocols&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeystoreType&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslProtocol&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslProvider</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTruststoreType</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>autoCommitIntervalMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>checkCrcs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>clientId</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>fetchWaitMaxMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metadata
 MaxAgeMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metricReporters</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>noOfMetricsSample&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>metricsSampleWindowMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>reconnectBackoffMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>retryBackoffMs&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosInitCmd&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosBeforeReloginMinTime&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosRenewJitter&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>kerberosRenewWindowFactor&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslCipherSuites</p></td></tr><tr><td colspan="1" rowspan="1" cl
 ass="confluenceTd"><p>sslEndpointAlgorithm</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslKeymanagerAlgorithm&#160;</p></td></tr><tr><td colspan="1" rowspan="1" class="confluenceTd"><p>sslTrustmanagerAlgorithm&#160;</p></td></tr></tbody></table></div><p>&#160;</p><h3 id="Kafka-Samples">Samples</h3><h4 id="Kafka-Camel2.16orolder.1">Camel 2.16 or older</h4><p>Consuming messages:</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
 <script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[from(&quot;kafka:localhost:9092?topic=test&amp;zookeeperHost=localhost&amp;zookeeperPort=2181&amp;groupId=group1&quot;).to(&quot;log:input&quot;);
 ]]></script>
-</div></div><p>Producing messages:</p><p>See unit tests of camel-kafka for more examples</p><p></p><h2 id="Kafka-Endpoints">Endpoints</h2>
+</div></div><p>Producing messages:</p><p>See unit tests of camel-kafka for more examples</p><h4 id="Kafka-Camel2.17ornewer.1">Camel 2.17 or newer</h4><p>Consuming messages:</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
+<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[from(&quot;kafka:localhost:9092?topic=test&amp;groupId=testing&amp;autoOffsetReset=earliest&amp;consumersCount=1&quot;)
+						.process(new Processor() {
+							@Override
+							public void process(Exchange exchange)
+									throws Exception {
+								String messageKey = &quot;&quot;;
+								if (exchange.getIn() != null) {
+									Message message = exchange.getIn();
+									Integer partitionId = (Integer) message
+											.getHeader(KafkaConstants.PARTITION);
+									String topicName = (String) message
+											.getHeader(KafkaConstants.TOPIC);
+									if (message.getHeader(KafkaConstants.KEY) != null)
+										messageKey = (String) message
+												.getHeader(KafkaConstants.KEY);
+									Object data = message.getBody();
+
+
+									System.out.println(&quot;topicName :: &quot;
+											+ topicName + &quot; partitionId :: &quot;
+											+ partitionId + &quot; messageKey :: &quot;
+											+ messageKey + &quot; message :: &quot;
+											+ data + &quot;\n&quot;);
+								}
+							}
+						}).to(&quot;log:input&quot;);
+]]></script>
+</div></div><p>&#160;</p><p>Producing messages:</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
+<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[from(&quot;direct:start&quot;).process(new Processor() {
+					@Override
+					public void process(Exchange exchange) throws Exception {
+						exchange.getIn().setBody(&quot;Test Message from Camel Kafka Component Final&quot;,String.class);
+						exchange.getIn().setHeader(KafkaConstants.PARTITION_KEY, 0);
+						exchange.getIn().setHeader(KafkaConstants.KEY, &quot;1&quot;);
+					}
+				}).to(&quot;kafka:localhost:9092?topic=test&quot;);
+]]></script>
+</div></div><p>&#160;</p><p></p><h2 id="Kafka-Endpoints">Endpoints</h2>
 
 <p></p><p>Camel supports the <a shape="rect" href="message-endpoint.html">Message Endpoint</a> pattern using the <a shape="rect" class="external-link" href="http://camel.apache.org/maven/current/camel-core/apidocs/org/apache/camel/Endpoint.html">Endpoint</a> interface. Endpoints are usually created by a <a shape="rect" href="component.html">Component</a> and Endpoints are usually referred to in the <a shape="rect" href="dsl.html">DSL</a> via their <a shape="rect" href="uris.html">URIs</a>. </p>