Kafka 架构
Broker : 作为一个后台服务。
Producer和Consumer作为SDK，将SDK引入工程当中，从外部拿数据，通过Producer的sdk发送给broker，通过Consumer的SDK将数据拿到程序当中。
如何刷新整个集群的元信息（Producer如何维护缓存的整个集群Broker的元信息）？
Producer在向某个Broker发送消息失败之后，会主动触发刷新Broker元信息
Producer会周期性地刷新Broker缓存的信息
Consumer如何发现Broker？Consumer如何选择连接到Broker
会涉及到Topic和Partition
Topic&Partition
Topic
逻辑概念，同一个Topic的消息可分布在一个或多个节点（Broker）上
一个Topic包含一个或者多个Partition
每条消息都属于且仅属于一个Topic
Producer发布数据时，必须指定该消息发布到哪一个Topic
Consumer订阅消息时，也必须指定订阅哪个Topic的消息
Partition
物理概念，一个Partition只分布于一个Broker上（不考虑备份）
一个Partition物理上对应一个文件夹
一个Partition包含多个Segment（Segment对用户透明，用户无需感知）
一个Segment对应一个文件
Segment由一个个不可变记录组成
记录只会被append到Segment中，不会被单独删除或者修改
清除过期日志时，直接删除一个或多个Segment
默认kafka会将数据保存168小时。
Sync Producer（同步Producer）
低延迟
低吞吐率
无数据丢失
Aync Producer（异步Producer）
高延迟
高吞吐率
可能会有数据丢失
