Hi Mark, When you send your message to Kafka, do you as well set the message key or you just set the partition key? Perhaps it would be great if you can post an example for your route with the headers/body that you set, that could help us here to troubleshoot the issue. Also, how many partitions do you have in your topic?
Regards, Omar On Fri, Apr 16, 2021 at 5:10 PM Mark Nuttall <mknutt...@gmail.com> wrote: > Camel version: 3.9.0 > > Issue: when consuming from one kafka topic and producing to another, > setting the partition key causes the write to fail. After a few seconds it > will fail with this error: > > Error during processing. Exchange[2729AA824AE4E97-0000000000000000]. Caused > by: [org.apache.kafka.common.errors.TimeoutException - Topic some-topic not > present in metadata after 60000 ms.] > > The topic does exist. If i produce to the topic without the partition key > OR I produce to the topic with a partition key via the producerTemplate it > works just fine. > I am pretty sure in the past i have done this and it worked. > > Has anyone else seen this? Any ideas? I do have a work around (i.e. use > Spring's kafkaTemplate.). > > Mark >
