前言
1)由于consumer在消费过程中可能会出现断点宕机等故障,consumer恢复后,需要从故障前的位置继续消费,所以consumer需要实时记录自己消费到了那个offset,以便故障恢复后继续消费。
2)在0.11版本之前消费者消费的offset信息会记录在zookeeper,0.11(含)之后Kafka选择将消费者消费的offset信息会记录到本地Kafka集群。
So
–zookeeper 和 --bootstrap是对消费者offset存储位置的一个选择,目前建议使用–bootstrap。