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