camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "karthik.premkumar" <karthik.premku...@gmail.com>
Subject RE: Camel kafka multiple consumer question
Date Thu, 28 Jul 2016 06:21:52 GMT
Hi, 
How did you manage to change the partition Key when producing the messages,
coz. when I tried to change the partition Key as part of the header in the
messages , getting this error ...


org.apache.camel.CamelExecutionException: Exception occurred during
execution on the exchange: 
Exchange[Message: KeyedMessage(SampleTopic,1,1,[B@11add17a)]
	at
org.apache.camel.util.ObjectHelper.wrapCamelExecutionException(ObjectHelper.java:1635)
....
Caused by: kafka.common.FailedToSendMessageException: Failed to send
messages after 3 tries.
	at
kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
	at kafka.producer.Producer.send(Producer.scala:77)

BR
Karthik




--
View this message in context: http://camel.465427.n5.nabble.com/Camel-kafka-multiple-consumer-question-tp5781284p5785526.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message