windows使用sarama往kafka发送数据

1. 首先先在本地安装好java，打开cmd，输入java -version，出现以下信息代表java安装成功。

1. 之后���次安装zookeeper和kafka并启动，详细安装与启动步骤可参考：

   【Kafka】Windows下安装Kafka（图文记录详细步骤）

2. 新写一个producer.go文件

package mainimport ("fmt""github.com/IBM/sarama")func main() {// 1.生产者配置cfg := sarama.NewConfig()cfg.Producer.RequiredAcks = sarama.WaitForAll          // ACKcfg.Producer.Partitioner = sarama.NewRandomPartitioner // 分区cfg.Producer.Return.Successes = true                   //确认// 2.连接kafkaclient, err := sarama.NewSyncProducer([]string{"127.0.0.1:9092"}, cfg)if err != nil {fmt.Printf("producer closed, err:", err)return}defer client.Close()// 3.封装消息msg := &sarama.ProducerMessage{}msg.Topic = "shopping"msg.Value = sarama.StringEncoder("go IBM sarama kafka")// 4.发送消息pid, offset, err := client.SendMessage(msg)if err != nil {fmt.Printf("send msg failed, err:%v", err)return}fmt.Printf("pid:%d, offset:%d", pid, offset)}

多运行几次

4. 使用命令行打开消费者

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic shopping --from-beginning

这时候就可以查看得到生产者发送过来的消息了