Hi,
i use the camel-kafka component and when i send a message to a topic it
raise an error : No partition key set.
t is due to the new api of the component. on the wiki page there is a sample
for the consumer xml dsl but
none for the provider,
<from
uri="kafka:localhost:9092?topic=orders&zookeeperHost=localhost&zookeeperPort=2181&groupId=orders"/>
any idea ?
thx
Best Regards
Bruno
Message History
---------------------------------------------------------------------------------------------------------------------------------------
RouteId ProcessorId Processor
Elapsed (ms)
[route7 ] [route7 ]
[servlet:///customers/neworder?httpMethodRestrict=POST
] [ 10]
[route7 ] [restBinding3 ] [
] [ 3]
[route7 ] [to4 ] [direct:customerNewOrder
] [ 4]
[route3 ] [log1 ] [log
] [ 1]
[route3 ] [to1 ]
[kafka:localhost:9092?topic=orders&zookeeperHost=localhost&zookeeperPort=2181
] [ 2]
Exchange
---------------------------------------------------------------------------------------------------------------------------------------
Exchange[
Id ID-P-7ZZ3CGBI-58294-1417540637830-1-2
ExchangePattern InOut
Headers {accept=*/*, accept-encoding=gzip,deflate,sdch,
accept-language=fr-FR,fr;q=0.8,en-US;q=0.6,en;q=0.4,
breadcrumbId=ID-P-7ZZ3CGBI-58294-1417540637830-1-1,
CamelHttpCharacterEncoding=UTF-8, CamelHttpMethod=POST, CamelHttpPath=,
CamelHttpQuery=null,
CamelHttpServletRequest=org.apache.catalina.connector.RequestFacade@1350201,
CamelHttpServletResponse=org.apache.catalina.connector.ResponseFacade@116b42c,
CamelHttpUri=/customers/neworder,
CamelHttpUrl=http://localhost:8080/customers/neworder,
CamelRedelivered=false, CamelRedeliveryCounter=0,
CamelServletContextPath=/customers/neworder, connection=keep-alive,
content-length=55, Content-Type=application/json,
cookie=_pk_id.2.1fff=026a212c399ad03f.1410797639.15.1411684275.1411681543.,
dnt=1, host=localhost:8080,
origin=chrome-extension://hgmloofddffdnphfgcellkdfbfbjeloo,
user-agent=Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML,
like Gecko) Chrome/35.0.1916.153 Safari/537.36}
BodyType org.apache.camel.converter.stream.InputStreamCache
Body [Body is instance of org.apache.camel.StreamCache]
]
Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
org.apache.camel.CamelExchangeException: No partition key set.
Exchange[Message: [Body is instance of org.apache.camel.StreamCache]]
at
org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:67)
--
View this message in context:
http://camel.465427.n5.nabble.com/camel-kafka-provider-no-partition-key-tp5759971.html
Sent from the Camel - Users mailing list archive at Nabble.com.
