[发生错误时如何重试kafka消息-春季云流

Question

我对Kafka还是很陌生。我正在使用春季云流Kafka进行生产和消费

@StreamListener(Sink.INPUT)
 public void process(Order order) {

       try {
      // have my message processing 

    }
    catch( exception e ) {
       //retry here that record..
     }
    }
 }

只是想知道如何执行重试？对此的任何帮助都将受到高度赞赏

Answer 1

使用内置的生成器重试是正确处理各种错误而不会丢失消息，但是作为开发人员，您仍然必须能够处理其他类型的错误。

这些包括：

• 不可恢复的经纪人错误，例如有关邮件大小，授权的错误错误等]
• [将消息发送到代理之前发生的错误，例如，seriali-zation错误
• 生产者用尽所有重试尝试或生产者使用的可用内存由于使用了所有内存而被填满重试时存储消息