kafka集群
2016-06-11 15:09:00 0 举报
Kafka集群是由多个Kafka broker组成的分布式系统,主要用于处理高吞吐量的实时数据流。每个broker都是一个独立的Kafka服务器,负责存储和处理消息。Kafka集群通过Zookeeper进行协调和管理,确保数据的一致性和可用性。当生产者向Kafka集群发送消息时,消息会被分发到不同的broker上,消费者可以从任何一个broker上读取消息。这种分布式架构使得Kafka集群具有高并发、高可用和可扩展性等优点,广泛应用于大数据处理、实时监控和日志收集等领域。
作者其他创作
大纲/内容
topic_A
Broker.KafkaApis.handle
ReplicaManager
partition_1
partition_3
topic_B
最新存活brokers
broker_1
topicA-1
topicA_0
00000000000000000000.log00000000000000000000.index00000000000000000000.timeindex00000000000000000123.log00000000000000000123.index00000000000000000123.timeindex00000000000000000273.log00000000000000000273.index00000000000000000273.timeindex
partition_4
msg
Kafka Cluser
topicB-1
AdminManager
producer
affected brokers
Controller
broker_2
partition_2
watch
zookeeperbrokerpath
consumer
broker_4
broker_3
Kafka Cluster
partition_5
req
BrokerRequest
partition_6
controller
topicA-0
zookeeperbrokerStatePath
brokers
partition1
partition2
partition3
partition_8
topicB-0
topicA-3
一个broker宕机回调
topicA-2
topicB-3
ClientRequest
Coordinator
topicB-2
partition_7
0 条评论
下一页