kafka Consumer的实现比较简单, 类似 kafka producer, 按照 sarama 的go语言实现, 简单说下:

Consumer -> partitionConsumer -> brokerConsumer -> Broker

partition 会发送MetadataRequest请求到kafka Broker 获取 topic partition的leader, 创建相应的Broker对象.