这篇博客是用来记录用go安装及操作kafka库的时候踩到的坑~

安装kafka库

首先我参考了博客:https://blog.csdn.net/tflasd1157/article/details/81985722和https://blog.csdn.net/u011596455/article/details/80073841

在go get github.com/Shopify/sarama安装过程中出现了

package golang.org/x/net/proxy: unrecognized import path "golang.org/x/net/proxy" (https fetch: Get https://golang.org/x/net/proxy?go-get=1: dial tcp 216.239.37.1:443: connectex: A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond.)

起初我以为是被墙了的原因,后来借用同学的ssrr节点FQ后还是没能解决。

git clone https://github.com/golang/net

随后继续go get,然后又是报这个错。。

# github.com/DataDog/zstd
cc1.exe: sorry, unimplemented: 64-bit mode not compiled in

意思是mingw需要下载64位版本,而系统自带的是32位,所以又参考惹这篇博客安装mingw64:https://www.cnblogs.com/ggg-327931457/p/9694516.html

安装之前的gcc版本

【golang】kafka _ JavaClub全栈架构师技术笔记

 

还没安装又弹出个错误

【golang】kafka _ JavaClub全栈架构师技术笔记

折腾了半天试了各种方法还是不好使最后结果把校园网换成热点竟然成了。。成了。。。。

 安装好之后修改配置变量,把其他所有有关mingw配置全删了,替换成刚下载的mingw64/bin

【golang】kafka _ JavaClub全栈架构师技术笔记

 

继续执行go get github.com/Shopify/sarama

顺利安装成功~

go操作kafka

首先启动zookeeper和kafka

创建了一个main.go

go run main.go后消费者执行

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

成功