Kafka进阶
上QQ阅读APP看本书,新人免费读10天
设备和账号都新为新人

1.3.1 消息服务器

Broker是消息的代理,Producers向Broker的指定Topic写消息,Consumers从Broker拉取指定Topic的消息,然后进行业务处理,Broker在中间起到一个代理保存消息的中转站的作用。

Broker没有副本机制,一旦Broker宕机,该Broker的消息将都不可用。消费者可以回溯到任意位置重新从Broker进行消息的消费,当消费者发生故障时,可以选择最小的offset(id)重新读取消费者消息。

关于Broker的详细内容,会在后续的章节中进一步介绍。