zoukankan      html  css  js  c++  java
  • Kafka

    Kafka体系架构=M个producer +N个broker +K个consumer+ZK集群

    producer:生产者

    Broker:服务代理节点,Kafka服务实例。
    n个组成一个Kafka集群,通常一台机器部署一个Kafka实例,一个实例挂了其他实例仍可以使用,体现了高可用

    consumer:消费者
    消费topic 的消息, 一个topic 可以让若干个consumer消费,若干个consumer组成一个 consumer group ,一条消息只能被consumer group 中一个consumer消费,若干个partition 被若干个consumer 同时消费,达到消费者高吞吐量

    topic :主题

    partition: 一个topic 可以拥有若干个partition(从 0 开始标识partition ),分布在不同的broker 上, 实现发布与订阅时负载均衡。producer 通过自定义的规则将消息发送到对应topic 下某个partition,以offset标识一条消息在一个partition的唯一性。
    一个partition拥有多个replica,提高容灾能力。
    replica 包含两种类型:leader 副本、follower副本,
    leader副本负责读写请求,follower 副本负责同步leader副本消息,通过副本选举实现故障转移。
    partition在机器磁盘上以log 体现,采用顺序追加日志的方式添加新消息、实现高吞吐量

  • 相关阅读:
    【UOJ 121】Hzwer的陨石
    【UOJ 666】古老的显示屏
    【UOJ 222】正方形二分型
    【UOJ 654】虫洞问题
    【UOJ 226】最近公共祖先
    【UOJ 92】有向图的强连通分量
    poj2139 Floyd
    poj1631 dp,最长上升子序列
    poj1065&1548 dp,最长上升子序列,偏序与反偏序
    poj1458(裸LCS)
  • 原文地址:https://www.cnblogs.com/ysit/p/11660135.html
Copyright © 2011-2022 走看看