camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From umang <umangkedia1...@gmail.com>
Subject Apache camel and kafka integration
Date Wed, 03 Sep 2014 18:12:27 GMT
I was trying to test camel integration with kafka as explained here
(https://github.com/ipolyzos/camel-kafka/wiki)

Following is my code

    public class KafkaTest {
    
        public static void main(String args[]) throws Exception {
            CamelContext context = new DefaultCamelContext();
    
            context.addRoutes(new RouteBuilder() {
                public void configure() {
                   
from("kafka:test?zkConnect=localhost:2181&metadataBrokerList=localhost:9092")
                    .process(new Processor() {
                        @Override
                        public void process(Exchange exchange) throws
Exception {
                            System.out.println(exchange.getIn().getBody());
                        }
                    })
                    .end();
                }
            });
    
            context.start();
            while (true) {
    
            }
        }
    }

However, I am getting the following error

    Exception in thread "main"
org.apache.camel.FailedToCreateRouteException: Failed to create route
route1: Route(route1)[[From[kafka:test?zkConnect=localhost:2181&amp;...
because of Failed to resolve endpoint:
kafka://test?amp%3BmetadataBrokerList=localhost%3A9092&zkConnect=localhost%3A2181
due to: Failed to resolve endpoint:
kafka://test?amp%3BmetadataBrokerList=localhost%3A9092&zkConnect=localhost%3A2181
due to: There are 2 parameters that couldn't be set on the endpoint. Check
the uri if the parameters are spelt correctly and that they are properties
of the endpoint. 

    Unknown parameters=[{metadataBrokerList=localhost:9092,
zkConnect=localhost:2181}]

Please suggest what could be missing.



--
View this message in context: http://camel.465427.n5.nabble.com/Apache-camel-and-kafka-integration-tp5756022.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message