Kafka 学习笔记之 High Level Consumer相关参数

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)
上一篇:Consumer设计-high/low Level Consumer


下一篇:Kafka 学习笔记之 Consumer API