[SM-2770] KAFKA CAMEL PRODUCER : Set class partitioner in Spring XML file

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 6.1.0
• Fix Version/s: 6.1.5, 7.0.2
• Component/s: servicemix-camel, servicemix-components
• Assignee: Unassigned
• Reporter: Bendaoud
• Created: 15/Dec/15 15:14
• Updated: 06/Apr/17 18:36

Description

Hello,
I am using camel to get a message from mqtt and to publish it to kafka topic. However, kafka topic has three partitions. So i have decided to use a partitioner class to choose how feed the partitions.
My camel configuration.

<camel:from uri="mqtt://ibm?host=tcp://0.0.0.0:1883&subscribeTopicNames=kafka" />

<camel:to uri="kafka:0.0.0.0:9092?topic=camel_arrosage&zookeeperHost=10.60.160.30&zookeeperPort=2181&groupId=MoB&serializerClass=kafka.serializer.StringEncoder&partitioner=Kafka.RoundRobinPartitioner"/>

I developed partitioner class ==> Kafka.RoundRobinPartitioner
But when i was starting this route, i catched this error :

Exception in thread "SpringOsgiExtenderThread-6" org.apache.camel.FailedToCreateProducerException: Failed to create Producer for endpoint: Endpoint[kafka://0.0.0.0:9092?groupId=MoB&partitioner=Kafka.RoundRobinPartitioner&serializerClass=kafka.serializer.StringEncoder&topic=camel_arrosage&zookeeperHost=0.0.0.0&zookeeperPort=2181]. Reason: java.lang.ClassNotFoundException: Kafka.RoundRobinPartitioner not found by org.apache.servicemix.bundles.kafka_2.10 [238]

Can anyone help me ?