Broker 一个kafka节点就是一个Broker
Topic 通过topic来归类
Partition 一个topic消息可能很多,我们将一个topic的消息进行分区partition,放到不同的broker中,一个broker又可以存放不同topic的partition
Producer 生成对应topic的消息
Consumer 消费监听topic的消息
ConsumerGroup 多个Consumer组成一个Consumer group,不同的group可以消费同一条消息,
但是一个group中只有一个consumer可以消费同一条消息
commit log 一个partition对应着一个commit log,partition中的消息就是message 序列,组成一个commit log
offset commit log中的每一个message都有在该log中唯一的offset,consumer通过自己维护持有的offset 来控制消费partition中的消息顺序
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)