如何为 spring-kafka 创建的所有 MessageListenerContainer 设置 RecordInterceptor
How to set RecordInterceptor for all the MessageListenerContainers created by spring-kafka
我正在使用 spring-kafka 2.5.4 和 spring boot 2.3.2。我有一些用@StreamListener 注释的方法。我想为所有方法添加一个通用拦截器。我一直在用 @EnableKafka 和 ConcurrentKafkaListenerContainerFactory bean 尝试它，但它不起作用。
我也不想自己配置 ConsumerFactory，但让 spring-kafka 来处理它。我只想在现有配置的基础上构建并在其上添加我的 RecordInterceptor。
spring-cloud-stream 不使用容器工厂，它创建自己的容器。
使用 spring-cloud-stream，您需要添加一个 ListenerContainerCustomizer bean 来修改容器。
我正在使用 spring-kafka 2.5.4 和 spring boot 2.3.2。我有一些用@StreamListener 注释的方法。我想为所有方法添加一个通用拦截器。我一直在用 @EnableKafka 和 ConcurrentKafkaListenerContainerFactory bean 尝试它，但它不起作用。
我也不想自己配置 ConsumerFactory，但让 spring-kafka 来处理它。我只想在现有配置的基础上构建并在其上添加我的 RecordInterceptor。
spring-cloud-stream 不使用容器工厂，它创建自己的容器。
使用 spring-cloud-stream，您需要添加一个 ListenerContainerCustomizer bean 来修改容器。