Apache Camel - Kafkaプロデューサー：トピック名を動的に設定する

Question

私はラクダベースのアプリケーションを持っています（XMLで記述されたルートを持つspring）。私はそれがXMLファイルに事前にパターンごとにプロデューサーを作成することはできませんので、入力されたメッセージをカフカトピックの不明な数（ファイル名パターンとトピック名の間の構成可能な一致に基づいて）にルーティングできるようにしたいと思います。

は、理想的には...パーティションIDと同様に、メッセージヘッダにトピックを設定できるようになり

誰もが提案を持っていますか？

Answer 1

最後に可能です。私はカフカ消費者の間違った情報源を紹介していました。最近のリリースでは、それは私が望むのとまったく同じように動作します。

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

したがって、動的にトピックを選択するには、メッセージにKafkaCOnstants.TOPICヘッダーを設定する必要があります。