我有一个storm拓扑来处理来自kafka的消息，并根据手头的任务在cassandra中进行http调用/保存。信息一到我就处理。由于来自外部源（如http）的响应，很少有消息没有被完全处理。我想实现一个指数退避机制，以便在http服务器不响应/返回错误消息的情况下重试一段时间。我能想到一些我能实现它们的想法。我想知道他们中的哪一个将是一个更好的解决方案，如果有任何其他解决方案，我可以使用容错。由于这是用来实现指数退避，每个消息将有不同的延迟时间。
发送另一个主题在Kafka，这是消费后。我的首选方案。我知道我们可以使用Kafka偏移量，所以在后期使用消息。我怎么也找不到文档/示例代码来做同样的事情。如果有人能帮我解决这个问题，那真的很有帮助。
编写消息cassandra/redis，并编写一个调度程序来获取尚未处理的消息，并将其发送给kafka，以便我的storm拓扑可以使用它(其他遗留项目中的现有解决方案（非storm））
延迟发送到beanstalk（其他遗留项目（非storm）中的现有解决方案）。我多么希望避免使用此解决方案，并且仅在我无法选择的情况下使用它）。
而这正是我想做的。我找不到实现delayprocessinguntil的文档，正如kafka中提到的，使用高级使用者的延迟队列实现
我以前用beanstalk做过数据存储和延迟的预定工作，但我更喜欢用kafka。