Java培训课程分享:深入了解Kafka架构1.Kafka数据处理步骤1.1生产者生成的消息发送给经纪人；1.2leader状态的Broker接收消息，并写入相应的主题；1.3leader状态的经纪人收到后，会发送给Follow状态的经纪人作为副本备份；1.4消费者在代理中消费消息。2.Kafka核心组件2.1生产者:消息生产者生成的消息将被发送到一个主题；2.2消费者:新闻消费者，消费的新闻内容来自一个话题；2.3主题:根据主题对消息进行分类，主题本质上是一个目录，即具有相同主题消息被分类到同一个目录中；2.4代理:每个kafka实例(或每个kafka服务器节点)都是一个代理，一个代理可以有多个主题；2.5Zookeeper:Zookeeper集群不是kafka内部的一个组件，但是kafka依靠Zookeeper集群来保存元信息，所以这里声明一下它的重要性。3.代理和集群独立的Kafka服务器称为broker。broker接收来自生产者的消息，设置消息的偏移量，并将消息提交到磁盘进行存储。Broker为消费者提供服务，响应读取分区的请求，并返回已经提交到磁盘的消息。根据具体的硬件及其