Kafka Consumer的SeekToCurrentErrorHandler的Spring Xml配置

问题描述

我正在将Kafka与我的一个应用程序集成。由于设计限制，我只需要使用XML配置，而不要使用Spring注释和Springboot。

我能够使用XML配置使用来自Kafka主题的消息。但是为了应用异常处理并将错误消息发送到死主题，我无法找到有用的资源。

你能对此有所启发吗？

下面是xml文件中的代码段。

<bean id="container1" class="org.springframework.kafka.listener.ConcurrentMessageListenerContainer">
    <constructor-arg>
        <bean class="org.springframework.kafka.core.DefaultKafkaConsumerFactory">
            <constructor-arg>
              <map>
                <entry key="bootstrap.servers" value=<bootstrap-servers> />
                <entry key="group.id" value=<group-id> />
                <entry key="auto.offset.reset" value="earliest" />
                <entry key="enable.auto.commit" value="false" />
                <entry key="concurrency" value="3" />
                <entry key="key.deserializer" value="org.apache.kafka.common.serialization.StringDeserializer" />
                <entry key="value.deserializer" value="org.apache.kafka.common.serialization.StringDeserializer" />
              </map>
            </constructor-arg>
        </bean>
    </constructor-arg>
    <constructor-arg>
        <bean class="org.springframework.kafka.listener.ContainerProperties">
            <constructor-arg name="topics" value="<topic-name>" />
            <property name="pollTimeout" value="2000"></property>
            <property name="AckMode" value="MANUAL"></property>
            <property name="syncCommits" value="true"></property>
        </bean>
    </constructor-arg>
    <property name="errorHandler" value="org.springframework.kafka.listener.SeekToCurrentErrorHandler" />
  </bean>

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

apache-kafka spring