Apache Camel - Kafka Producer: Den Themennamen dynamisch setzen

Question

Ich habe eine camel-basierte Anwendung (Quelle mit in XML beschriebenen Routen). Ich möchte, dass es in der Lage ist, die Eingangsnachrichten an eine unbekannte Anzahl von Kafka-Themen zu leiten (basierend auf einer konfigurierbaren Übereinstimmung zwischen Dateinamenmustern und Themennamen), sodass ich keinen Produzenten pro Muster im Voraus in der XML-Datei erstellen kann.

Im Idealfall würden wir in der Lage sein, das Thema im Message-Header zu setzen, wie die Partitions-ID ...

Hat jemand einen Vorschlag hat?

Answer 1

Endlich ist es möglich. Ich bezog mich auf die falschen Quellen des Kafka-Konsumenten. In den letzten Releases verhält es sich genau so, wie ich es mir erhofft hatte.

topic = exchange.getIn().getHeader(KafkaConstants.TOPIC, topic, String.class); 

So hat man die KafkaCOnstants.TOPIC-Header in der Nachricht zu setzen, um dynamisch das Thema wählte.