0
点赞
收藏
分享

微信扫一扫

Kafka中消费者方式--zookeeper和--bootstrap


1)由于consumer在消费过程中可能会出现断点宕机等故障,consumer恢复后,需要从故障前的位置继续消费,所以consumer需要实时记录自己消费到了那个offset,以便故障恢复后继续消费。

2)在之后版本,消费者消费的offset信息会从zookeeper改到到本地Kafka集群。

So
–zookeeper --bootstrap是对消费者offset存储位置的一个选择,目前建议使用–bootstrap。



消费者同时使用ZK和bootstrap方式消费测试:
https://www.oschina.net/question/215898_2309529
Kafka中bootstrap-server、broker-list和zookeeper的区别
https://www.cnblogs.com/tonglin0325/p/8810313.html


举报

相关推荐

0 条评论