2

KafkaTemplate の実装から、実際の Kafka Producer にアクセスできないことがわかりました。metrics()この Producer ラッピングは適切かもしれませんが、やのように必要な Kafka Producer のメソッドがいくつかありpartitionsFor(java.lang.String topic)ます。KafkaTemplate では、実際の Kafka Producer メソッドをラップする同じメソッドを使用できます。これは新しいバージョンで実装される可能性がありますか? 実装してプル リクエストを送信できますか?

4

1 に答える 1

3

Kafka のガイドラインに従って、 はDefaultKafkaProducerFactory常に同じプロデューサーを返すため、呼び出しcreateProducerて単一のプロデューサーへの参照を取得しても安全です。

プロデューサーの呼び出しclose()は無視されます。

ただし、テンプレートからプロデューサーへのアクセスを提供するためにGitHub イシューを開きました。

于 2016-09-07T12:57:36.680 に答える