如何通过 Shopify sarama 抵消消费者恢复

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《如何通过 Shopify sarama 抵消消费者恢复》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

我读到kafka提供了一个消费者客户端库，它允许通过保存zookeeper中最后读取的偏移量来进行恢复（不能100%确定它的存储位置）。

是否可以对 Sarama 消费者做同样的事情？

假设我正在读取直到偏移量 550，我的消费者崩溃了 5 分钟，我们现在处于偏移量 700，但我想从偏移量 550 恢复消费。

这可能不需要我自己保存状态吗？ 我认为确实如此，但我不明白如何实现。

我找到了 sarama.OffsetNewest/Oldest 但这不是我要找的...

解决方案

Kafka消费者过去将偏移量存储在Zookeeper中，但现在他们直接将它们存储在Kafka中。请参阅 Kafka 文档中的 Consumer section。

Sarama 处理得很好，Sarama 消费者默认会在 Kafka 中提交（存储）偏移量。

看看 Sarama Consumer example。最初，此示例从主题末尾开始，但重新启动后，它将从最后的位置重新启动。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~