gpt4 book ai didi

apache-kafka-streams - Kafka Streams - 重试消息

转载 作者:行者123 更新时间:2023-12-04 08:20:10 25 4
gpt4 key购买 nike

我有一个具有外部依赖性的 Kafka 流应用程序。如果依赖项不可用,我想稍后重新处理消息。我无法控制偏移量,因为流是在内部进行的。什么是最好的完成这个?

最佳答案

您需要将消息放入存储区,然后将其从存储区中取出并重试。

您可以在常规处理期间或通过安排标点符号进行重试。

查看文档了解更多详情:https://docs.confluent.io/current/streams/developer-guide/processor-api.html#defining-a-stream-processor

关于apache-kafka-streams - Kafka Streams - 重试消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49186470/

25 4 0