【发布时间】：2016-10-20 15:58:53
【问题描述】：
在我的用例中，我创建了一个消费者，读取消息并将它们写入弹性搜索。然后，我提交它们（没有自动提交）。 在某些情况下，写作可能会失败，所以我不承诺。是否有一个选项可以配置 zookeeper 以重新发送在一定时间后未发送的 msg？
【问题讨论】：
-
我无法关注... Zookeeper 是一个“分布式共识服务”并且不发送消息...。您还用“apache-kafka”标记了这个问题——您是否从那里消费消息?请编辑您的问题并提供更多详细信息。
标签： node.js apache-kafka apache-zookeeper