此示例显示了一个完全工作的控制台应用程序，该应用程序可以为主题中的所有分区使用，并为每个分区创建一个goroutine：
https://github.com/shopify/sarama/blob/master/tools/kafka-console-consumer/kafka-console-consumer.go
它链接在你在问题中发布的帖子的末尾。
它基本上创造了一个消费者：

c, err := sarama.NewConsumer(strings.Split(*brokerList, ","), config)

然后获取所需主题的所有分区：

func getPartitions(c sarama.Consumer) ([]int32, error) {
    if *partitions == "all" {
        return c.Partitions(*topic)
    }
...

然后为每个分区创建一个partitionconsumer，并使用不同goroutine中的每个分区：

for _, partition := range partitionList {
    pc, err := c.ConsumePartition(*topic, partition, initialOffset)
    ....

    wg.Add(1)
    go func(pc sarama.PartitionConsumer) {
        defer wg.Done()
        for message := range pc.Messages() {
            messages <- message
        }
    }(pc)

}