sample-sarama-consumer-subscription.go

topic := "topic-to-subscribe-to" //e.g. user-created-topic
partitionList := consumer.Partitions(topic) //get all partitions
messages := make(chan *sarama.ConsumerMessage, 256)
initialOffset := sarama.OffsetOldest //offset to start reading message from
for _, partition := range partitionList {  
     pc, _ := consumer.ConsumePartition(topic, partition, initialOffset)
     go func(pc sarama.PartitionConsumer) {
         for message := range pc.Messages() {
             messages <- message //or call a function that writes to disk
         }
     }(pc)
}