欢迎光临散文网 会员登陆 & 注册

马老师apacHe shardIngsphere实战与核心源码剖析

2023-04-02 14:05 作者:呵呵呵呵呵sp  | 我要投稿

** parition是物理上的概念,每个topic包含一个或多个partition,创建topic时可指定parition数量。每个partition对应于一个文件夹,该文件夹下存储该partition的数据和索引文件**

Producer

** 负责发布消息到Kafka broker**

Consumer

** 消费消息。每个consumer属于一个特定的consuer group(可为每个consumer指定group name,若不指定group name则属于默认的group)。使用consumer high level API时,同一topic的一条消息只能被同一个consumer group内的一个consumer消费,但多个consumer group可同时消费这一消息。**


马老师apacHe shardIngsphere实战与核心源码剖析的评论 (共 条)

分享到微博请遵守国家法律