參看一下文件https://pykafka.readthedocs.io/en/latest/index.html

#從kafka消費

#consumer_area = topic_area.get_simple_consumer(auto_offset_reset=OffsetType.LATEST)

#從ZOOKEEPER消費

consumer_area = topic_area.get_balanced_consumer(

consumer_group=b"zs_download_04", # 自己命令

auto_offset_reset=OffsetType.LATEST,#在consumer_group存在的情況下，設定此變數，表示從最新的開始取

#auto_offset_reset=OffsetType.EARLIEST,

#reset_offset_on_start=True,

auto_commit_enable=True,

#auto_commit_interval_ms=1,

zookeeper_connect=ZK_LIST

)