camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From build...@apache.org
Subject svn commit: r923809 - in /websites/production/camel/content: cache/main.pageCache kafka.html
Date Sat, 27 Sep 2014 12:18:19 GMT
Author: buildbot
Date: Sat Sep 27 12:18:18 2014
New Revision: 923809

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 Sat Sep 27 12:18:18 2014
@@ -96,7 +96,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="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[kafka:server:port[?options]
 ]]></script>
-</div></div><p>&#160;</p><h3 id="Kafka-Options">Options</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"><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">groupId</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">partitioner</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">consumerStreams</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">clientId</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">zookeeperSessionTimeoutMs</td><td
colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" row
 span="1" class="confluenceTd">&#160;</td></tr><tr><td colspan="1"
rowspan="1" class="confluenceTd">zookeeperConnectionTimeoutMs</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">zookeeperSyncTimeMs</td><td colspan="1"
rowspan="1" class="confluenceTd">&#160;</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</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">Producer Options</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" r
 owspan="1" class="confluenceTd"><p>producerType</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">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</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
co
 lspan="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">requestTimeoutMs</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;</t
 d></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="confluenceTd">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="confluence
 Td">&#160;</td></tr></tbody></table></div></div><h3
id="Kafka-ConsumerOptions">Consumer Options</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="c
 onfluenceTd">&#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-Samples">Samples</h3><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">Options</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="confluenceTd">&#160;</td><td colspan="1" row
 span="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">groupId</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">partitioner</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">consumerStreams</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">clientId</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">zookeeperSessionTimeoutMs</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">zookeeperConnectionTimeoutMs</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">zookeeperSyncTimeMs</td><td colspan="1" rowspan="1" class="confluenceTd">&#160;</td><td
colspan="1" rowspan="1" class="confluenceTd">&#160;</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">Producer Options</h3><div class="confluenceTableSmall"><div
class="ta
 ble-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>&#160;</p></td><td
colspan="1" rowspan="1" class="confluenceTd">&#160;</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</td><td colspan="1"
rowspan="1" class="confluence
 Td">&#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">requestTimeoutMs</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="confluenceTd">serializerClass</td><td colspan="1"
row
 span="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">Consumer Options</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-Samples">Samples</h3><p>Consuming messages:</p><div class="code
panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
 <script class="theme: Default; brush: java; gutter: false" 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>



Mime
View raw message