windows使用sarama往kafka发送数据

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

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

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

2. 新写一个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)
}

多运行几次

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

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

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

本网站所收集的部分公开资料来源于AI生成和互联网，转载的目的在于传递更多信息及用于网络分享，并不代表本站赞同其观点和对其真实性负责，也不构成任何其他建议。