camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andrea Cosentino <ancosen1...@yahoo.com.INVALID>
Subject Re: camel-kafka Unknown parameters zookeeperHost, zookeeperPort
Date Fri, 11 Nov 2016 08:35:32 GMT
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: ancosen1985@yahoo.com
Twitter: @oscerd2
Github: oscerd



On Friday, November 11, 2016 9:17 AM, Damage_Shadow <schedov@outlook.com> 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.

Mime
View raw message