Hi, You may need to check out the code iployzos and build it yourself, as the patch[1] is not in the current Apache Camel trunk now.
[1]https://issues.apache.org/jira/browse/CAMEL-7339 -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On September 4, 2014 at 2:12:55 AM, umang (umangkedia1...@gmail.com) wrote: > 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&... > 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. >
