[camel] branch master updated: Polish the docuement of karfak

[ningjiang]

This is an automated email from the ASF dual-hosted git repository.

ningjiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new 5c804dd  Polish the docuement of karfak
5c804dd is described below

commit 5c804dde83fc8986f79119e8951d1afc97083826
Author: Willem Jiang <jiangni...@huawei.com>
AuthorDate: Mon May 14 09:20:42 2018 +0800

    Polish the docuement of karfak
---
 .../camel-kafka/src/main/docs/kafka-component.adoc | 26 +++++++++++++++-------
 1 file changed, 18 insertions(+), 8 deletions(-)

diff --git a/components/camel-kafka/src/main/docs/kafka-component.adoc 
b/components/camel-kafka/src/main/docs/kafka-component.adoc
index ac32dca..7d89604 100644
--- a/components/camel-kafka/src/main/docs/kafka-component.adoc
+++ b/components/camel-kafka/src/main/docs/kafka-component.adoc
@@ -247,9 +247,13 @@ camelContext.addRoutes(new RouteBuilder() {
     @Override
     public void configure() throws Exception {
         from("kafka:" + TOPIC + "?brokers=localhost:{{kafkaPort}}" +
-                     "&groupId=A" +                            //
-                     "&autoOffsetReset=earliest" +             // Ask to start 
from the beginning if we have unknown offset
-                     "&offsetRepository=#offsetRepo")          // Keep the 
offsets in the previously configured repository
+                     // Setup the topic and broker address
+                     "&groupId=A" +
+                     // The consumer processor group ID
+                     "&autoOffsetReset=earliest" +
+                     // Ask to start from the beginning if we have unknown 
offset
+                     "&offsetRepository=#offsetRepo")
+                     // Keep the offsets in the previously configured 
repository
                 .to("mock:result");
     }
 });
@@ -308,8 +312,11 @@ camelContext.addRoutes(new RouteBuilder() {
     @Override
     public void configure() throws Exception {
         from("kafka:" + TOPIC + "?brokers=localhost:{{kafkaPort}}" +
-                     "&groupId=A" +                            //
-                     "&sslContextParameters=#ssl")             // Reference 
the SSL configuration
+                     // Setup the topic and broker address
+                     "&groupId=A" +
+                     // The consumer processor group ID
+                     "&sslContextParameters=#ssl")
+                     // Reference the SSL configuration
                 .to("mock:result");
     }
 });
@@ -365,13 +372,15 @@ In XML:
 [source,xml]
 ----
 <!-- simple -->
-<bean id="insertDbIdemRepo" 
class="org.apache.camel.processor.idempotent.kafka.KafkaIdempotentRepository">
+<bean id="insertDbIdemRepo"
+  
class="org.apache.camel.processor.idempotent.kafka.KafkaIdempotentRepository">
   <property name="topic" value="idempotent-db-inserts"/>
   <property name="bootstrapServers" value="localhost:9091"/>
 </bean>
 
 <!-- complex -->
-<bean id="insertDbIdemRepo" 
class="org.apache.camel.processor.idempotent.kafka.KafkaIdempotentRepository">
+<bean id="insertDbIdemRepo"
+  
class="org.apache.camel.processor.idempotent.kafka.KafkaIdempotentRepository">
   <property name="topic" value="idempotent-db-inserts"/>
   <property name="maxCacheSize" value="10000"/>
   <property name="consumerConfig">
@@ -408,7 +417,8 @@ You can then use the `KafkaManualCommit` from Java code 
such as a Camel `Process
 [source,java]
 ----
 public void process(Exchange exchange) {
-    KafkaManualCommit manual = 
exchange.getIn().getHeader(KafkaConstants.MANUAL_COMMIT, 
KafkaManualCommit.class);
+    KafkaManualCommit manual =
+        exchange.getIn().getHeader(KafkaConstants.MANUAL_COMMIT, 
KafkaManualCommit.class);
     manual.commitSync();
 }
 ----

-- 
To stop receiving notification emails like this one, please contact
ningji...@apache.org.