2016-09-07 10 views
2

私はKafkaTemplateの実装から、実際のカフカプロデューサにアクセスできないことがわかりました。このプロデューサーのラッピングは良いかもしれませんが、カフカプロデューサーからは、metrics()partitionsFor(java.lang.String topic)のようないくつかのメソッドが必要です。 KafkaTemplateでは、実際のカフカプロデューサメソッドをラップするこれらの同じメソッドを使用できます。 これは新しいバージョンで実装される可能性がありますか? 私はそれを実装してプルリクエストを行うことができますか?KafkaTemplateからトピックのメタデータを取得

答えて

2

カフカのガイドラインによれば、DefaultKafkaProducerFactoryは常に同じプロデューサを返しますので、createProducerを呼び出して1つのプロデューサへの参照を取得しても安全です。

プロデューサでclose()を呼び出すことは無視されます。

しかし、GitHub Issueを開いて、テンプレートからプロデューサにアクセスできるようにしました。

関連する問題