kafka监听topic消费_大白话 + 13 张图解 Kafka

• 前言
• 一、Kafka基础
  • 消息系统的作用
  • 1.Topic 主题
  • 2.Partition 分区
  • 3.Producer - 生产者
  • 4.Consumer - 消费者
  • 5.Message - 消息
• 二、kafka的集群架构
  • Replica - 副本
  • Consumer Group - 消费者组
  • Controller
  • kafka和zookeeper如何配合工作
• 加餐时间
  • 1.Kafka性能好在什么地方？
  • 2.日志分段存储
  • 3.Kafka的网络设计
• finally

• 《Java 2019 超神之路》
• 《Dubbo 实现原理与源码解析 —— 精品合集》
• 《Spring 实现原理与源码解析 —— 精品合集》
• 《MyBatis 实现原理与源码解析 —— 精品合集》
• 《Spring MVC 实现原理与源码解析 —— 精品合集》
• 《Spring Boot 实现原理与源码解析 —— 精品合集》
• 《数据库实体设计合集》
• 《Java 面试题 —— 精品合集》
• 《Java 学习指南 —— 精品合集》

前言

应大部分的小伙伴的要求，在Yarn之前先来一个kafka的小插曲，轻松愉快。

一、Kafka基础

消息系统的作用

应该大部份小伙伴都清楚，用机油装箱举个例子

所以消息系统就是如上图我们所说的仓库，能在中间过程作为缓存，并且实现解耦合的作用。

引入一个场景，我们知道中国移动，中国联通，中国电信的日志处理，是交给外包去做大数据分析的，假设现在它们的日志都交给了你做的系统去做用户画像分析。

按照刚刚前面提到的消息系统的作用，我们知道了消息系统其实就是一个模拟缓存 ，且仅仅是起到了缓存的作用 而并不是真正的缓存，数据仍然是存储在磁盘上面而不是内存。

1.Topic 主题

kafka学习了数据库里面的设计，在里面设计了topic（主题），这个东西类似于关系型数据库的表

此时我需要获取中国移动的数据，那就直接监听TopicA即可

2.Partition 分区

kafka还有一个概念叫Partition（分区ÿ