go - 在汇合的kafka go中阅读来自kafka主题的消息时，如何使用确认？

Question

我正在开发一个将许多消息发送到客户端的推送通知。消息被发布到主题中，而订阅者从同一主题中读取消息。在从主题偏移读取消息后立即发生错误的情况下，即使我无法发送消息，我的订阅服务器也需要阅读下一条消息并将其发送。错误是指服务器故障或严重的故障。
如何阅读带有确认的消息？

Answer 1

我不确定我是否理解你的意思

In case of errors right after reading message from topic offset isincremented and even though I could not send message my Subscriberneeds to read the next message and send it

据我了解，您想管理消费者如何处理确认(提交给_consumer_offsets)。
因此，Kafka允许消费者通过在__consumer_offsets主题中向Kafka发送消息来跟踪其在每个分区中的位置(偏移)。
提供3种选择:

自动提交:使用 enable.auto.commit = true ，每隔auto.commit.interval.ms自动提交一次(默认5s)。

同步提交:显式地使用commitSync()进行同步提交，该提交将提交poll()返回的最新偏移量，并在失败之​​前重试，直到获得确认为止。

异​​步提交:先前的方法要等到代理响应确认提交后，它才能使速度变慢。我们可以使用commitAsync()，它不会阻塞，并且在失败时不会重试。它更快。我们可以将回调传递给commitAsync()。

因此，基本上，您可以让提交得到自动处理。同步提交并等待代理的确认或通过回调异步提交。
希望这能回答您的问题。
最好的祝福。