KafkaTemplate の実装から、実際の Kafka Producer にアクセスできないことがわかりました。metrics()
この Producer ラッピングは適切かもしれませんが、やのように必要な Kafka Producer のメソッドがいくつかありpartitionsFor(java.lang.String topic)
ます。KafkaTemplate では、実際の Kafka Producer メソッドをラップする同じメソッドを使用できます。これは新しいバージョンで実装される可能性がありますか? 実装してプル リクエストを送信できますか?
質問する
932 次
1 に答える
3
Kafka のガイドラインに従って、 はDefaultKafkaProducerFactory
常に同じプロデューサーを返すため、呼び出しcreateProducer
て単一のプロデューサーへの参照を取得しても安全です。
プロデューサーの呼び出しclose()
は無視されます。
ただし、テンプレートからプロデューサーへのアクセスを提供するためにGitHub イシューを開きました。
于 2016-09-07T12:57:36.680 に答える