クライアントサイドのカフカプロデューサーはどのように働いていますか？

Question

私はkafkaクラスタを所有していると仮定し、私はKafkaにデータを送信するいくつかのクライアント（Webアプリケーション）を求めます。どのように私のKafkaブローカに接続するプロデューサを作成するクライアントが、クライアントがカスタムパーティションを使用する場合は正しい方法ですか？

Answer 1

AFAIK一部のパティシパを使用するようにKafkaクライアント/クラスタを制限することはできません。しかし、あなたのプロデューサーがいくつかのファサードインターフェースの背後に隠れている場合は、あなたのメッセージのKeyが正しい方法で作成されているかどうかを確かめることができます。

あなたのファサードには、たとえばを受け入れることができます。この場合、keyフィールドとvalueフィールドにアクセスできます。

https://kafka.apache.org/090/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html