Golang 操作 Kafka 样例
是在不同的机器,同一机 器对同一个分区也只可能存放一个副本(包括自己)。 Consumer:消费者,即消息的消费方,是消息的出口。 Consumer Group:我们可以将多个消费组组成一个消费者组,在kafka的设计中同一个分 区的数据只能被消费者组中的某一个消费者消费。同一个消费者组的消费者可以消费同一个 topic的不同分区的数据,这也是为了提高kafka的吞吐量! 2.1.2. ⼯作流程 我们看上⾯的架构图中,producer就是生产者,是数据的入口。Producer在写入数据的时候会把数据 写入到leader中,不会直接将数据写入follower!那leader怎么找呢?写入的流程又是什么样的呢?我 们看下图: 1.⽣产者从Kafka集群获取分区leader信息 2.⽣产者将消息发...阅读全文