search

childe / healer

golang lib for kafka
22 stars 18 forks source link

如果设置了 AutoCommit :false，关闭的时候就不要提交了 #16

Closed childe closed 4 years ago

childe commented 4 years ago

我现在只想消费一下看看有哪些数据，而不是作为一个长期的消费者

这种情况下 offset 提交上去没意义

还有不少情况 需要由用户自己判断消费进度，如果按照从kafka获取到哪里就提交到哪里，有些数据可能还没处理

如果关闭的时候提交了, 可能有些数据在 Healer 的 chan 里面, 并没有被用户消费到, 这个时候会有数据丢失.