Because from 2.17 to 2.18 we upgrade Kafka to 0.10.x https://github.com/apache/camel/blob/camel-2.18.x/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
We are now using only the Java API for both producer and consumer. -- Andrea Cosentino ---------------------------------- Apache Camel PMC Member Apache Karaf Committer Apache Servicemix Committer Email: [email protected] Twitter: @oscerd2 Github: oscerd On Friday, November 11, 2016 9:17 AM, Damage_Shadow <[email protected]> wrote: 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.
