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.
