[
https://issues.apache.org/jira/browse/CAMEL-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895613#comment-15895613
]
Claus Ibsen commented on CAMEL-10586:
-------------------------------------
[~jstrachan] if you try again with 2.19.0-SNAPSHOT then it should be easier. It
uses string out of the box, and you wont need to marshal to string first etc.
And you can set the key and partition key in the endpoint uri
{code}
to("kafka://kafka:9092?topic=cheese&groupId=group1&key=1234&partitionKey=2")
{code}
> make the kafka endpoint a little easier to use
> ----------------------------------------------
>
> Key: CAMEL-10586
> URL: https://issues.apache.org/jira/browse/CAMEL-10586
> Project: Camel
> Issue Type: Improvement
> Components: camel-kafka
> Reporter: james strachan
> Assignee: Claus Ibsen
> Fix For: 2.19.0
>
>
> when using, say, JMS or activemq endpoints you can send text to a destination
> and it all kinda works OOTB. However it seems pretty hard to actually send
> anyhting to the kafka endpoint.
> I wonder if we could do a bit more to make it easier to use as a camel
> endpoint?
> e.g. if I invoke a HTTP endpoint then pipe the result to Kafka I get:
> {code}
> org.apache.kafka.common.errors.SerializationException: Can't convert value of
> class org.apache.camel.converter.stream.CachedOutputStream$WrappedInputStream
> to class org.apache.kafka.common.serialization.StringSerializer specified in
> value.serializer
> {code}
> seems like it'd be nice if there's no configured serializer to assume its
> bytes / string?
> If I send to the dataformat endpoint first to force conversion to a String:
> {code}
> to("dataformat:string:unmarshal").
> to("kafka://kafka:9092?topic=cheese&groupId=group1")
> {code}
> then I get:
> {code}
> 17:34:10.212 [Camel (Funktion) thread #0 - timer://foo] WARN
> o.a.c.component.kafka.KafkaProducer - No message key or partition key set
> {code}
> and there's no easy way to pass in a message key or partition key via the URI
> parameters from what I can see.
> I wonder if we should support a URI parameter for setting the partition key +
> message key?
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
