java - Kafka プロデューサー インターセプター

Question

プロデューサーによって Kafka トピックに発行されたメッセージの検証を行うためにインターセプターを追加しようとしています。Kafka トピックによって実行されるスキーマ検証に加えて、いくつかの検証を行う必要があります。私が従った手順は次のとおりです。

1. ProducerInterceptor インターフェイスを拡張する Java クラスを作成しました。
2. クラスをコンパイルし、クラスパスに含まれるフォルダーに配置されるjarファイルを作成しました。
3. Kafka インストール内の producer.properties に intercetors.classes= classname を追加しました。

しかし、トピックにメッセージを発行すると、作成したカスタム インターセプター クラスが呼び出されません。（エラーも発生していません。メッセージはトピックに完全に公開されています）。

https://cwiki.apache.org/confluence/display/KAFKA/KIP-42%3A+Add+Producer+and+Consumer+Interceptorsを参照しました

これについてアドバイスをください。

Answer 1

プロパティ名は intercetors.classes ではなく、interceptor.classes です。