main.pageCache how-do-i-edit-the-website.html kafka.html

buildbot Tue, 22 Mar 2016 02:20:07 -0700

Author: buildbot
Date: Tue Mar 22 09:19:12 2016
New Revision: 983411

Log:
Production update by buildbot for camel


Modified:
    websites/production/camel/content/cache/main.pageCache
    websites/production/camel/content/how-do-i-edit-the-website.html
    websites/production/camel/content/kafka.html

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

Modified: websites/production/camel/content/how-do-i-edit-the-website.html
==============================================================================
--- websites/production/camel/content/how-do-i-edit-the-website.html (original)
+++ websites/production/camel/content/how-do-i-edit-the-website.html Tue Mar 22 
09:19:12 2016
@@ -75,7 +75,7 @@
        <tbody>
         <tr>
         <td valign="top" width="100%">
-<div class="wiki-content maincontent"><h2 
id="HowdoIeditthewebsite-HowdoIeditthewebsite?">How do I edit the 
website?</h2><p>The website is all contained on a Wiki so that you can <a 
shape="rect" href="contributing.html">contribute</a> providing you are happy to 
license all your contributions under the <a shape="rect" class="external-link" 
href="http://www.apache.org/licenses/LICENSE-2.0";>Apache Software License 
version 2.0</a></p><h3 
id="HowdoIeditthewebsite-YoumusthavesignedanICLAtobeabletoeditthewikipages">You 
must have signed an ICLA to be able to edit the wiki pages</h3><ul><li>Download 
and print the Apache Contributor License Agreement from <a shape="rect" 
class="external-link" 
href="http://www.apache.org/dev/new-committers-guide.html";>here</a>. You need 
to sign it and fax it to Apache. In the past I've found its often faster to 
also post it via snail mail</li><li>wait for your name to appear on the <a 
shape="rect" class="external-link" href="http://people.apache.org/committer-
 index.html">list of received CLAs</a> see the <em>unlisted CLAs</em> 
section.</li><li>send an email to the <a shape="rect" 
href="mailing-lists.html">Camel dev forum</a> about that your ICLA have been 
received at Apache, and include your 
<strong>wiki</strong>&#160;<strong>username</strong>&#160;in the 
email.</li><li>A Camel PMC member will then verify that ASF have received the 
ICLA and assign edit rights to your username, using <a shape="rect" 
href="https://cwiki.apache.org/confluence/spaces/spacepermissions.action?key=CAMEL";>this
 page</a>.</li></ul><h3 id="HowdoIeditthewebsite-Howtoedit">How to 
edit</h3><p>To edit a page, just hit the <strong>edit</strong> link right at 
the bottom of any page. To be able to edit you need to register with 
confluence.</p><div class="confluence-information-macro 
confluence-information-macro-information"><p class="title">Spam 
Prevention</p><span class="aui-icon aui-icon-small aui-iconfont-info 
confluence-information-macro-icon"></span><div class="confl
 uence-information-macro-body"><p>We have been attacked by spammers so we are 
running a spam-avoiding scheme. So you have to ask to be added to the editing 
group of Confluence. This is quick and easy to do.</p><p>First click edit on a 
page to get to the confluence site of <a shape="rect" class="external-link" 
href="http://cwiki.apache.org/confluence/display/CAMEL/Index";>http://cwiki.apache.org/confluence/display/CAMEL/Index</a>
 then register.</p><p>Then send an mail to the <a shape="rect" 
class="external-link" 
href="http://www.nabble.com/Camel-Development-f36429.html"; 
rel="nofollow">developer forum</a> giving details of your confluence and/or 
JIRA username and we can grant you the necessary editing 
karma.</p></div></div><p>Note that after you've changed the wiki it is 
immediately rendered on the <a shape="rect" class="external-link" 
href="http://cwiki.apache.org/CAMEL/";>http://cwiki.apache.org/CAMEL/</a> site 
so you can test it out; then up to an hour or two later it is updated on th
 e Apache site.</p><h3 id="HowdoIeditthewebsite-Howthesiteworks">How the site 
works</h3><p>There are a few special pages; for example the <a shape="rect" 
href="navigation.html">Navigation</a> page is the right hand navigation bar and 
the <a shape="rect" href="quicklinks.html">QuickLinks</a> is the top right 
navigation bar.</p><p>Other useful <a shape="rect" href="site.html">links</a> 
are</p><p>This page contains the main navigation links to the parts which make 
up the Site layout.
+<div class="wiki-content maincontent"><h2 
id="HowdoIeditthewebsite-HowdoIeditthewebsite?">How do I edit the 
website?</h2><p>The website is all contained on a Wiki so that you can <a 
shape="rect" href="contributing.html">contribute</a> providing you are happy to 
license all your contributions under the <a shape="rect" class="external-link" 
href="http://www.apache.org/licenses/LICENSE-2.0";>Apache Software License 
version 2.0</a></p><h3 
id="HowdoIeditthewebsite-YoumusthavesignedanICLAtobeabletoeditthewikipages">You 
must have signed an ICLA to be able to edit the wiki pages</h3><ul><li>Download 
and print the Apache Contributor License Agreement from <a shape="rect" 
class="external-link" 
href="http://www.apache.org/dev/new-committers-guide.html";>here</a>. You need 
to sign it and fax it to Apache. In the past I've found its often faster to 
also post it via snail mail</li><li>wait for your name to appear on the <a 
shape="rect" class="external-link" href="http://people.apache.org/unlistedcl
 as.html">list of received CLAs</a> see the <em>unlisted CLAs</em> 
section.</li><li>send an email to the <a shape="rect" 
href="mailing-lists.html">Camel dev forum</a> about that your ICLA have been 
received at Apache, and include your 
<strong>wiki</strong>&#160;<strong>username</strong>&#160;in the 
email.</li><li>A Camel PMC member will then verify that ASF have received the 
ICLA and assign edit rights to your username, using <a shape="rect" 
href="https://cwiki.apache.org/confluence/spaces/spacepermissions.action?key=CAMEL";>this
 page</a>.</li></ul><h3 id="HowdoIeditthewebsite-Howtoedit">How to 
edit</h3><p>To edit a page, just hit the <strong>edit</strong> link right at 
the bottom of any page. To be able to edit you need to register with 
confluence.</p><div class="confluence-information-macro 
confluence-information-macro-information"><p class="title">Spam 
Prevention</p><span class="aui-icon aui-icon-small aui-iconfont-info 
confluence-information-macro-icon"></span><div class="confluen
 ce-information-macro-body"><p>We have been attacked by spammers so we are 
running a spam-avoiding scheme. So you have to ask to be added to the editing 
group of Confluence. This is quick and easy to do.</p><p>First click edit on a 
page to get to the confluence site of <a shape="rect" class="external-link" 
href="http://cwiki.apache.org/confluence/display/CAMEL/Index";>http://cwiki.apache.org/confluence/display/CAMEL/Index</a>
 then register.</p><p>Then send an mail to the <a shape="rect" 
class="external-link" 
href="http://www.nabble.com/Camel-Development-f36429.html"; 
rel="nofollow">developer forum</a> giving details of your confluence and/or 
JIRA username and we can grant you the necessary editing 
karma.</p></div></div><p>Note that after you've changed the wiki it is 
immediately rendered on the <a shape="rect" class="external-link" 
href="http://cwiki.apache.org/CAMEL/";>http://cwiki.apache.org/CAMEL/</a> site 
so you can test it out; then up to an hour or two later it is updated on the A
 pache site.</p><h3 id="HowdoIeditthewebsite-Howthesiteworks">How the site 
works</h3><p>There are a few special pages; for example the <a shape="rect" 
href="navigation.html">Navigation</a> page is the right hand navigation bar and 
the <a shape="rect" href="quicklinks.html">QuickLinks</a> is the top right 
navigation bar.</p><p>Other useful <a shape="rect" href="site.html">links</a> 
are</p><p>This page contains the main navigation links to the parts which make 
up the Site layout.
 
 </p><ul class="childpages-macro"><li><a shape="rect" 
href="banner.html">Banner</a></li><li><a shape="rect" 
href="book.html">Book</a></li><li><a shape="rect" 
href="book-in-one-page.html">Book In One Page</a></li><li><a shape="rect" 
href="includes.html">Includes</a></li><li><a shape="rect" 
href="navigation.html">Navigation</a></li><li><a shape="rect" 
href="quicklinks.html">QuickLinks</a></li><li><a shape="rect" 
href="scratch-page.html">Scratch Page</a></li><li><a shape="rect" 
href="siteindex.html">SiteIndex</a></li><li><a shape="rect" 
href="sitemap.html">SiteMap</a></li><li><a shape="rect" 
href="site-update-ideas.html">Site Update Ideas</a></li></ul> </div>
         </td>

Modified: websites/production/camel/content/kafka.html
==============================================================================
--- websites/production/camel/content/kafka.html (original)
+++ websites/production/camel/content/kafka.html Tue Mar 22 09:19:12 2016
@@ -93,7 +93,7 @@
     &lt;!-- use the same version as your Camel core version --&gt;
 &lt;/dependency&gt;
 ]]></script>
-</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">
+</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 assumes 
it is 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,7 +102,7 @@
 </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>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)">Producer 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>serializerClass</p></td><td 
colspan="1" rowspan="46" class="confluenceTd"><p class="p1"><span 
class="s1"><span class="nolink"><a shape="rect" class="external-link" 
href="http://kafka.apache.org/documentation.html#producerconfigs";>http://kafka.apache.org/documentation.html#producerconfigs</a></span></span></p><p
 class="p1"><span class="s1"><span class="nolink">serializerClass : <span 
class="pl-s">org.apache.kafka.common.serialization.StringSerializer</span></span></span></p><p
 class="p1"><span class="s1"><span class="nolink">keySerializerClass : <span 
class="s1"><span class="nolink"><span 
class="pl-s">org.apache.kafka.common.serialization.StringSerializer</span></span></span></span></
 span></p><p>partitioner : <span 
class="pl-s">org.apache.kafka.clients.producer.internals.DefaultPartitioner<span
 class="pl-pds">&#160;</span></span></p><p>&#160;</p><p>&#160;</p><p 
class="p1"><span class="s1"><span class="nolink"><br 
clear="none"></span></span></p></td></tr><tr><td colspan="1" rowspan="1" 
class="confluenceTd"><p>keySerializerClass</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 co
 lspan="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="confluenceTd"><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" 
rowspa
 n="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>timeoutMs&#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="c
 onfluenceTd"><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="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" 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"><a shape="rect" class="external-link" 
href="http://kafka.apache.org/documentation.html#newconsumerconfigs";>
 
http://kafka.apache.org/documentation.html#newconsumerconfigs</a></span></span></p><p
 class="p1"><span class="s1"><span class="nolink">keyDeserializer : <span 
class="pl-s">org.apache.kafka.common.serialization.StringDeserializer</span></span></span></p><p
 class="p1"><span class="s1"><span class="nolink">valueDeserializer : <span 
class="s1"><span class="nolink"><span 
class="pl-s">org.apache.kafka.common.serialization.StringDeserializer</span></span></span></span></span></p><p>partitionAssignor
 : <span 
class="pl-s">org.apache.kafka.clients.consumer.RangeAssignor</span></p><p>&#160;</p><p
 class="p1"><span class="s1"><span class="nolink"><span class="s1"><span 
class="nolink"><span class="pl-s"><br 
clear="none"></span></span></span></span></span></p><p class="p1"><span 
class="s1"><span class="nolink"><br 
clear="none"></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>valu
 eDeserializer</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&#16
 0;</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" 
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&#1
 60;</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" 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</h
 4><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 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>Description</
 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">messageSendMaxRetries</t
 d><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">request
 TimeoutMs</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="conflu
 enceTd">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;</td></
 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="confluenceTd">
 &#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="confluenceTd">&
 #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 colspan="
 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 clas
 s="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>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)">Producer Options&#160;(Ca
 mel 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>serializerClass</p></td><td 
colspan="1" rowspan="46" class="confluenceTd"><p class="p1"><span 
class="s1"><span class="nolink"><a shape="rect" class="external-link" 
href="http://kafka.apache.org/documentation.html#producerconfigs";>http://kafka.apache.org/documentation.html#producerconfigs</a></span></span></p><p
 class="p1"><span class="s1"><span class="nolink">serializerClass : <span 
class="pl-s">org.apache.kafka.common.serialization.StringSerializer</span></span></span></p><p
 class="p1"><span class="s1"><span class="nolink">keySerializerClass : <span 
class="s1"><span class="nolink"><span 
class="pl-s">org.apache.kafka.common.serialization.StringSerializer</span></span></span></span></span
 ></p><p>partitioner : <span 
 >class="pl-s">org.apache.kafka.clients.producer.internals.DefaultPartitioner<span
 > class="pl-pds">&#160;</span></span></p><p>&#160;</p><p>&#160;</p><p 
 >class="p1"><span class="s1"><span class="nolink"><br 
 >clear="none"></span></span></p></td></tr><tr><td colspan="1" rowspan="1" 
 >class="confluenceTd"><p>keySerializerClass</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 
 >colspa
 n="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="confluenceTd"><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>timeoutMs&#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="confl
 uenceTd"><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="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" 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"><a shape="rect" class="external-link" 
href="http://kafka.apache.org/documentation.html#newconsumerconfigs";>http
 
://kafka.apache.org/documentation.html#newconsumerconfigs</a></span></span></p><p
 class="p1"><span class="s1"><span class="nolink">keyDeserializer : <span 
class="pl-s">org.apache.kafka.common.serialization.StringDeserializer</span></span></span></p><p
 class="p1"><span class="s1"><span class="nolink">valueDeserializer : <span 
class="s1"><span class="nolink"><span 
class="pl-s">org.apache.kafka.common.serialization.StringDeserializer</span></span></span></span></span></p><p>partitionAssignor
 : <span 
class="pl-s">org.apache.kafka.clients.consumer.RangeAssignor</span></p><p>&#160;</p><p
 class="p1"><span class="s1"><span class="nolink"><span class="s1"><span 
class="nolink"><span class="pl-s"><br 
clear="none"></span></span></span></span></span></p><p class="p1"><span 
class="s1"><span class="nolink"><br 
clear="none"></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>valueDes
 erializer</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" 
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" 
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><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><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">

svn commit: r983411 - in /websites/production/camel/content: cache/main.pageCache how-do-i-edit-the-website.html kafka.html

Reply via email to