windows使用sarama往kafka发送数据

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

2. 之后依次安装zookeeper和kafka并启动，详细安装与启动步骤可参考：
   【Kafka】Windows下安装Kafka（图文记录详细步骤）
   

3. 新写一个producer.go文件

package main

import (
	"fmt"
	"github.com/IBM/sarama"
)

func main() {
	// 1.生产者配置
	cfg := sarama.NewConfig()
	cfg.Producer.RequiredAcks = sarama.WaitForAll          // ACK
	cfg.Producer.Partitioner = sarama.NewRandomPartitioner // 分区
	cfg.Producer.Return.Successes = true                   //确认

	// 2.连接kafka
	client, 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)

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

多运行几次

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

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

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