Using latest camel-parent / camel-kafka
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-parent</artifactId>
<version>2.18.0</version>
</dependency>
1st problem - Need to explicitly add kafka_2.11 dependency as in camel-kafka
scope was changed to test.
2nd problem - Even if kafka_2.11 added, camel route fails to start :
Route:
from("kafka:{{UIKafkaIPAddress}}:{{KafkaPort}}" +
"?topic={{TopicName}}" +
"&zookeeperHost={{UIKafkaIPAddress}}" +
"&zookeeperPort={{ZookeeperPort}}" +
"&groupId={{KafkaGroupId}}" +
"&serializerClass=kafka.serializer.StringDecoder")
.log(LoggingLevel.INFO, simple("Raw ${body}").toString())
Exception :
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to
resolve endpoint:
kafka://10.10.14.127:9092?groupId=group1&serializerClass=kafka.serializer.StringDecoder&topic=topic&zookeeperHost=10.10.14.127&zookeeperPort=2181
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=[{zookeeperHost=10.10.14.127,
zookeeperPort=2181}]
Why Zookeeper options were removed?
--
View this message in context:
http://camel.465427.n5.nabble.com/camel-kafka-Unknown-parameters-zookeeperHost-zookeeperPort-tp5790021.html
Sent from the Camel - Users mailing list archive at Nabble.com.
