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)