kafka

ZooKeeper为kafka做负载均衡

2017-11-22  本文已影响1553人  bobcorbett

消息生产者:producer
消息消费者:consumer
主题:即Topic,由用户定义并配置在Kafka服务端,用于建立生产者和消费者之间的订阅关系:生产者发送消息到指定Topic下,消费者从这个Topic下消费消息。
Broker:即Kafka服务器,用于存储消息,在消息中间件中通常被称为Broker
消费者分组:Group
Offset:消息存储在Kafka的Broker上,消费者拉取消息数据的过程中需要知道消息在文件中的偏移量,这个偏移量就是所谓的Offset

ZooKeeper负责管理所有Broker服务器列表,并且建立了对应路径来对其进行管理/brokers/ids

每个Broker服务器在启动时,都会到ZooKeeper上进行注册,其节点路径为/broker/ids/[0...N]

Topic注册:Kafka当中,会将同一个Topic的消息分成多个区,分布到多个Broker上,这些分区信息和Broker的对应关系由ZooKeeper来维护

ZooKeeper负载均衡实现:
上一篇下一篇

猜你喜欢

热点阅读