camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Willem Jiang <willem.ji...@gmail.com>
Subject Re: Apache camel and kafka integration
Date Thu, 04 Sep 2014 03:22:54 GMT
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 (umangkedia1990@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.
>  


Mime
View raw message