This is an automated email from the ASF dual-hosted git repository. tsato pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-k-examples.git
commit b40180b6eae3d011a9c76e9c86878725f2ecc34e Author: Kuthumi Pepple <[email protected]> AuthorDate: Wed Jul 27 13:21:07 2022 +0100 format code in kafka example --- generic-examples/kafka/SampleKafkaConsumer.java | 16 ++++++++-------- .../kafka/sasl_ssl/SaslSSLKafkaConsumer.java | 8 ++++---- .../kafka/sasl_ssl/SaslSSLKafkaProducer.java | 14 +++++++------- 3 files changed, 19 insertions(+), 19 deletions(-) diff --git a/generic-examples/kafka/SampleKafkaConsumer.java b/generic-examples/kafka/SampleKafkaConsumer.java index 20e1eac..aebc3fd 100644 --- a/generic-examples/kafka/SampleKafkaConsumer.java +++ b/generic-examples/kafka/SampleKafkaConsumer.java @@ -20,13 +20,13 @@ import org.apache.camel.builder.RouteBuilder; public class SampleKafkaConsumer extends RouteBuilder { @Override public void configure() throws Exception { - log.info("About to start route: Kafka Server -> Log "); - from("kafka:{{consumer.topic}}?brokers={{kafka.host}}:{{kafka.port}}" - + "&maxPollRecords={{consumer.maxPollRecords}}" - + "&consumersCount={{consumer.consumersCount}}" - + "&seekTo={{consumer.seekTo}}" - + "&groupId={{consumer.group}}") - .routeId("FromKafka") - .log("${body}"); + log.info("About to start route: Kafka Server -> Log "); + from("kafka:{{consumer.topic}}?brokers={{kafka.host}}:{{kafka.port}}" + + "&maxPollRecords={{consumer.maxPollRecords}}" + + "&consumersCount={{consumer.consumersCount}}" + + "&seekTo={{consumer.seekTo}}" + + "&groupId={{consumer.group}}") + .routeId("FromKafka") + .log("${body}"); } } diff --git a/generic-examples/kafka/sasl_ssl/SaslSSLKafkaConsumer.java b/generic-examples/kafka/sasl_ssl/SaslSSLKafkaConsumer.java index 42ed3f5..527f689 100644 --- a/generic-examples/kafka/sasl_ssl/SaslSSLKafkaConsumer.java +++ b/generic-examples/kafka/sasl_ssl/SaslSSLKafkaConsumer.java @@ -22,9 +22,9 @@ import org.apache.camel.builder.RouteBuilder; public class SaslSSLKafkaConsumer extends RouteBuilder { @Override public void configure() throws Exception { - log.info("About to start route: Kafka -> Log "); - from("kafka:{{consumer.topic}}") - .routeId("FromKafka2Log") - .log("${body}"); + log.info("About to start route: Kafka -> Log "); + from("kafka:{{consumer.topic}}") + .routeId("FromKafka2Log") + .log("${body}"); } } diff --git a/generic-examples/kafka/sasl_ssl/SaslSSLKafkaProducer.java b/generic-examples/kafka/sasl_ssl/SaslSSLKafkaProducer.java index 85caeb5..383f1a0 100644 --- a/generic-examples/kafka/sasl_ssl/SaslSSLKafkaProducer.java +++ b/generic-examples/kafka/sasl_ssl/SaslSSLKafkaProducer.java @@ -23,12 +23,12 @@ import org.apache.camel.builder.RouteBuilder; public class SaslSSLKafkaProducer extends RouteBuilder { @Override public void configure() throws Exception { - log.info("About to start route: Timer -> Kafka "); - from("timer:foo") - .routeId("FromTimer2Kafka") - .setBody() - .simple("Message #${exchangeProperty.CamelTimerCounter}") - .to("kafka:{{producer.topic}}") - .log("Message correctly sent to the topic!"); + log.info("About to start route: Timer -> Kafka "); + from("timer:foo") + .routeId("FromTimer2Kafka") + .setBody() + .simple("Message #${exchangeProperty.CamelTimerCounter}") + .to("kafka:{{producer.topic}}") + .log("Message correctly sent to the topic!"); } }
