james strachan created CAMEL-10586:
--------------------------------------
Summary: 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: ka, kafka
Reporter: james strachan
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.4#6332)
