如何为int-kafka消息驱动通道适配器注入自定义RecordFilterStrategy？

你的配置逻辑顺序搞反了，还陷入了循环依赖：你试图让FilteringMessageListenerAdapter从containerProperties里获取消息监听器，但containerProperties本身又要引用这个filteringMessageListener，初始化时容器检测到监听器设置冲突，就抛出了这个错误。

正确的思路是：FilteringMessageListenerAdapter作为装饰器，需要直接包装你自己的业务消息监听器，而不是从容器配置里反向获取。具体配置步骤如下：

1. 先定义实际处理业务的消息监听器（比如你自己实现的MessageListener或AcknowledgingMessageListener）
2. 定义自定义的RecordFilterStrategy实现类
3. 用FilteringMessageListenerAdapter包装业务监听器和过滤策略
4. 最后在containerProperties中设置这个包装后的监听器

正确配置示例 #

<!-- 1. 业务消息监听器：处理实际的消息逻辑 -->
<bean id="businessMessageListener" class="com.your.path.YourBusinessMessageListener"/>

<!-- 2. 自定义消息过滤策略 -->
<bean id="recordFilterStrategy" class="com.some.path.YourCustomRecordFilterStrategy"/>

<!-- 3. 包装业务监听器，添加过滤能力 -->
<bean id="filteringMessageListener" class="org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter">
    <!-- 第一个参数：业务监听器 -->
    <constructor-arg ref="businessMessageListener"/>
    <!-- 第二个参数：过滤策略 -->
    <constructor-arg ref="recordFilterStrategy"/>
    <!-- 可选：设置为true表示丢弃的消息也要提交偏移量 -->
    <property name="ackDiscarded" value="true"/>
</bean>

<!-- 4. 容器配置，引用包装后的过滤监听器 -->
<bean id="containerProperties" class="org.springframework.kafka.listener.config.ContainerProperties">
    <constructor-arg name="topics">
        <list>
            <value>someTopic</value>
        </list>
    </constructor-arg>
    <property name="errorHandler" ref="listenerErrorHandler"/>
    <property name="messageListener" ref="filteringMessageListener"/>
</bean>

适配int-kafka:message-driven-channel-adapter的场景 #

如果你的消费者是通过<int-kafka:message-driven-channel-adapter>配置的，只需让适配器关联包含上述配置的监听器容器即可：

<int-kafka:message-driven-channel-adapter
        id="kafkaInboundAdapter"
        listener-container="kafkaListenerContainer"
        channel="inputChannel"/>

<!-- 监听器容器关联consumerFactory和配置好的containerProperties -->
<bean id="kafkaListenerContainer" class="org.springframework.kafka.listener.KafkaMessageListenerContainer">
    <constructor-arg ref="consumerFactory"/>
    <constructor-arg ref="containerProperties"/>
</bean>

这样配置后，容器初始化时会先创建业务监听器和过滤策略，再包装成带过滤能力的监听器，最后注入到容器配置中，完全避免了循环依赖和监听器冲突的问题。

内容的提问来源于stack exchange，提问作者N1kk1