Golang之发送消息至kafka

来看看

package main　　import (
　　"fmt"
　　"github.com/Shopify/sarama"
　　"time"
　　)
　　//消息写入kafka
　　func main() {
　　//初始化配置
　　config := sarama.NewConfig()
　　config.Producer.RequiredAcks = sarama.WaitForAll
　　config.Producer.Partitioner = sarama.NewRandomPartitioner
　　config.Producer.Return.Successes = true
　　//生产者
　　client, err := sarama.NewSyncProducer([]string{"127.0.0.1:9092"}, config)
　　if err != nil {
　　fmt.Println("producer close,err:", err)
　　return
　　}
　　defer client.Close()
　　var n int=0
　　for n