High Level Consumer相关参数
自动管理offset
- auto.commit.enable = true
- auto.commit.interval.ms = 60*1000
手动管理offset
- auto.commit.enable = false
- ConsumerConnector.commitOffsets();
offset存储
- offsets.storage = zookeeper (kafka)
- dual.commit.enabled = true (false)
Kafka 学习笔记之 High Level Consumer相关参数
原文:http://www.cnblogs.com/AK47Sonic/p/7294084.html