本文探讨了Kafka中enable.auto.commit参数的作用，即当该参数设置为true时，可以自动保存offset并读取错过消息的功能。此外，还介绍了0.9版本后offset与Zookeeper的关系已不再相关。
取决于 enable.auto.commit”
enable.auto.commit” -> (true: java.lang.Boolean) 可以保存offset，可以读取错过消息。（即使没有checkpoint）
不开自动提交的话 offset取决于 auto.offset.reset”
0.9以后offset已经和zk没关系
扫一扫
评论
被折叠的 条评论
为什么被折叠?
到【灌水乐园】发言
查看更多评论
添加红包
