如何在Kafka nodejs中延迟消费消息？
如何在Kafka nodejs中延迟消费消息？
提问于 2016-05-31 12:14:37
我正在使用NodeJS消费来自Kafka的消息，收到消息后，我会带着它在Elasticsearch中创建索引。这是我的代码片段：
kafkaConsumer.on('message', function (message) {
elasticClient.index({
index: 'test',
type: 'sample',
body: message
}, function (error, response) {
if (error) {
// Stop consuming message here
console.log(error);
}
console.log(response);
});
});我希望确保在继续使用下一条消息之前必须成功创建索引，因为我不希望丢失任何消息。
回答 2
Stack Overflow用户
发布于 2016-05-31 12:51:47
试试consumer.pause()/resume()吧。
pause()暂停使用者
resume()恢复消费者
Stack Overflow用户
发布于 2016-05-31 12:55:00
您可以暂停您的消费者，这样它就不会订阅和获取新消息。一旦你得到elasticClient的响应，你就可以恢复你的kafka消费者了。
kafkaConsumer.pause();
kafkaConsumer.resume();根据您的设置使用它。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/37545494
复制相关文章
点击加载更多
相似问题
Spring kafka消息消费延迟
Apache Kafka中消费者消费消息的延迟
Kafka 1.0 Streaming API: partitions消息消费延迟
NodeJS Kafka消费者收到重复的消息？
Kafka不消费消息
添加站长 进交流群
领取专属 10元无门槛券
AI混元助手 在线答疑
关注 腾讯云开发者公众号
洞察 腾讯核心技术
剖析业界实践案例
腾讯云开发者
