doru1004 commented on issue #1541: URL: https://github.com/apache/camel-k/issues/1541#issuecomment-645577988
Thanks for the reply, sure: ``` package org.apache.camel.kamel; import org.apache.camel.CamelContext; import org.apache.camel.Exchange; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.builder.component.ComponentsBuilderFactory; import org.apache.camel.impl.DefaultCamelContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public final class KafkaProducer { private KafkaProducer() { } public static void main(String[] args) throws Exception { LOG.info("Starting Kafka-Camel integration..."); CamelContext camelContext = new DefaultCamelContext(); // Add route to send messages to Kafka. camelContext.addRoutes(new RouteBuilder() { public void configure() { // Setup kafka component with the brokers. ComponentsBuilderFactory.kafka() .brokers("X.X.X.X:9092") .register(camelContext, "kafka"); [...] } }); } } ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org