S. *_*tty 5 apache-kafka-streams
我有一个具有外部依赖性的 Kafka 流应用程序。如果依赖项不可用，我想稍后重新处理消息。我无法控制偏移量，因为流是在内部进行的。什么是最好的完成这个？
您需要将消息放入存储中，然后将其从存储中取出并重试。
您可以在常规处理期间或通过安排标点符号来重试。
查看文档了解更多详细信息：https://docs.confluence.io/current/streams/developer-guide/processor-api.html#defining-a-stream-processor