如何处理Spring cloud流kafka流活页夹中的序列化错误？

Question

我正在使用Spring Cloud Stream Kafka Streams绑定器编写Kafka Streams应用程序。

当使用者将消息发布到输出主题时，可能会出现类似序列化错误或网络错误的错误。

在此代码中-

@Bean
public Function<KStream<Object, String>, KStream<Object, String>> process() {
    return (input) -> {
        KStream<Object, String> kt = input.flatMapValues(v -> Arrays.asList(v.toUpperCase().split("\\W+")));
        return kt;
    };
}

这里在发生错误时将消息返回输出主题，如何处理。除了RetryTemplate之外，Kafka流绑定器中是否有任何机制？

我正在使用Spring Cloud Stream Kafka Streams绑定器编写Kafka Streams应用程序。使用者将消息发布到输出主题时，可能会出现诸如序列化错误或...

Answer 1

请参见the Spring for Apache Kafka documentation。