本文介绍: 一个存放消息的组件生产者， 消费者， broker三部分*生产者和消费者（消费者主动拉取信息，然后删除）*发布订阅（）*一个topic有多个partition（副本（信息非全量），有分leader和follower）*消费者组（只消费leader的）（一个分区一个消费者处理）修改broker id修改ZK地址修改数据存放路径数据量先写道缓存 到达指定批次（默认16K），或等待（默认0秒）就发送*可以异步发送*可以异步发送回调*同步发送。
消息队列的两种模式
*生产者和消费者（消费者主动拉取信息，然后删除）
*发布订阅（）
kafka基础架构*一个topic有多个partition（副本（信息非全量），有分leader和follower）
*消费者组（只消费leader的）（一个分区一个消费者处理）
*zookeeper（）
怎么提高吞吐量
架构
声明：本站所有文章，如无特殊说明或标注，均为本站原创发布。任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。
