Golang 操作 Kafka 样例
消费者组中,每个消费者实例可以消费多个分区,但是每个分区最多只 能被消费者组中的⼀个实例消费。也就是说,如果有⼀个4个分区的主题,那么消费者组中最多只能有4 个消费者实例去消费,多出来的都不会被分配到分区。其实这也很好理解,如果允许两个消费者实例同 时消费同⼀个分区,那么就⽆法记录这个分区被这个消费者组消费的offset了。如果在消费者组中动态 的上线或下线消费者,那么Kafka集群会⾃动调整分区与消费者实例间的对应关系。 3. 操作Kafka 3.1.1. sarama Go语言中连接kafka使用第三方库: github.com/Shopify/sarama。 3.1.2. 下载及安装 go get github.com/Shopify/sarama 复制代码 注意事项: sarama...阅读全文