小编S. *_*tty的帖子

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