Oh, no other way to test? I thought kafka support is added in camel 2.13
On Thu, Sep 4, 2014 at 8:53 AM, Willem.Jiang [via Camel] < ml-node+s465427n5756036...@n5.nabble.com> wrote: > 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 ([hidden email] > <http://user/SendEmail.jtp?type=node&node=5756036&i=0>) 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. > > > > > > ------------------------------ > If you reply to this email, your message will be added to the discussion > below: > > http://camel.465427.n5.nabble.com/Apache-camel-and-kafka-integration-tp5756022p5756036.html > To unsubscribe from Apache camel and kafka integration, click here > <http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=5756022&code=dW1hbmdrZWRpYTE5OTBAZ21haWwuY29tfDU3NTYwMjJ8MTE0ODY2MTU2> > . > NAML > <http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> > -- Regards, Umang Kedia -- View this message in context: http://camel.465427.n5.nabble.com/Apache-camel-and-kafka-integration-tp5756022p5756037.html Sent from the Camel - Users mailing list archive at Nabble.com.
