添加 ProducerInterceptor - Kafka
Adding a ProducerInterceptor - Kafka
我试图在消息被序列化之前拦截它们，我看到已经有一个名为 ProducerInterceptor 的接口，可用于修改记录。做了一个实现那个接口的class，修改了数据后，新的class需要放在哪里，是不是还要修改一些文件？
在创建 KafkaProducer 对象时，将其传递到属性中，例如
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);
我试图在消息被序列化之前拦截它们，我看到已经有一个名为 ProducerInterceptor 的接口，可用于修改记录。做了一个实现那个接口的class，修改了数据后，新的class需要放在哪里，是不是还要修改一些文件？
在创建 KafkaProducer 对象时，将其传递到属性中，例如
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);