ProducerInterceptorを追加する - Kafka

Question

メッセージをシリアル化する前に傍受しようとしていますが、すでにProducerInterceptorというインターフェイスがあり、レコードを変更するために使用できます。そのインターフェイスを実装し、データを変更するクラスを作成した後、新しいクラスを配置する必要がある場合は、いくつかのファイルを変更する必要がありますか？

Answer 1

KafkaProducerオブジェクトを作成しているときに、プロパティに渡します。 9092 interceptor.classes = org.apache.kafka：私はそのようにプロパティを置く場合でも、私はこれらの追加のコマンドを入れると、インターセプタだけ--producer-小道具bootstrap.servers = localhostの `表示されます

Properties producerProps = new Properties(); 
producerProps.put(ProducerConfig.INTERCEPTOR_CLASSES_CONFIG, "fully qualified name of your interceptor class"); 
//... add other properties 
KafkaProducer<String,String> kProd = new KafkaProducer<>(producerProps);