golang基础-kafka、zookeeper搭建、go终端发送数据给kafka
2017-11-18 20:30
465 查看
zookeeper搭建
kafka搭建
kafka链接zookeeper
在go终端写入kafka
2、安装zookeeper3.3.6,下载地址:http://apache.fayea.com/zookeeper/
3、重命名conf/zoo_sample.cfg 为conf/zoo.cfg
4、编辑 conf/zoo.cfg,修改dataDir=D:\zookeeper-3.3.6\data\
4、运行bin/zkServer.cmd
启动zookeeper如下
2、打开config目录下的server.properties, 修改log.dirs为D:\kafka_logs,
3、修改advertised.host.name=服务器ip
4、启动kafka ./bin/windows/kafka-server-start.bat ./config/server.preperties
创建生产者sarama.NewSyncProducer
创建消息sarama.ProducerMessage
发送消息client.SendMessage
终端执行如下:我这里有个问题
然后在kafka命令窗口就能收到信息:截图如下
kafka搭建
kafka链接zookeeper
在go终端写入kafka
zookeeper搭建
1、安装JAVA-JDK,从oracle下载最新的SDK安装(我用的是1.8的)2、安装zookeeper3.3.6,下载地址:http://apache.fayea.com/zookeeper/
3、重命名conf/zoo_sample.cfg 为conf/zoo.cfg
4、编辑 conf/zoo.cfg,修改dataDir=D:\zookeeper-3.3.6\data\
4、运行bin/zkServer.cmd
启动zookeeper如下
kafka搭建
1、打开链接:http://kafka.apache.org/downloads.html下载kafka2.1.22、打开config目录下的server.properties, 修改log.dirs为D:\kafka_logs,
############################# Log Basics ############################# # A comma seperated list of directories under which to store log files log.dirs=/tmp/kafka-logs #log.dirs=E:\develop\kafka\kafka_logs
3、修改advertised.host.name=服务器ip
# root directory for all kafka znodes. zookeeper.connect=localhost:2181 # Timeout in ms for connecting to zookeeper zookeeper.connection.timeout.ms=6000 advertised.host.name=192.168.11.28
4、启动kafka ./bin/windows/kafka-server-start.bat ./config/server.preperties
kafka链接zookeeper
在go终端写入kafka
初始化NewConfig配置 sarama.NewConfig创建生产者sarama.NewSyncProducer
创建消息sarama.ProducerMessage
发送消息client.SendMessage
package main import ( "fmt" "github.com/Shopify/sarama" ) func main() { config := sarama.NewConfig() config.Producer.RequiredAcks = sarama.WaitForAll config.Producer.Partitioner = sarama.NewRandomPartitioner config.Producer.Return.Successes = true msg := &sarama.ProducerMessage{} msg.Topic = "nginx_log" msg.Value = sarama.StringEncoder("this is a good test, my message is good") client, err := sarama.NewSyncProducer([]string{"192.168.11.28:9092"}, config) if err != nil { fmt.Println("producer close, err:", err) return } defer client.Close() pid, offset, err := client.SendMessage(msg) if err != nil { fmt.Println("send message failed,", err) return } fmt.Printf("pid:%v offset:%v\n", pid, offset) }
终端执行如下:我这里有个问题
PS E:\golang\go_pro\src\safly> go run main.go send message failed, kafka server: In the middle of a leadership election, there is currently no leader for this partition and hence it is unavailable for writes. PS E:\golang\go_pro\src\safly> go run main.go pid:2 offset:0 pid:0 offset:0 pid:5 offset:0 pid:3 offset:0 pid:7 offset:0 pid:0 offset:1 pid:2 offset:1 pid:0 offset:2 pid:3 offset:1 pid:2 offset:2 pid:5 offset:1 pid:1 offset:0
然后在kafka命令窗口就能收到信息:截图如下
相关文章推荐
- golang基础-beego读取配置_输出log日志、tailf组件读取log、配置zookeeper_kafka、发送log至kafka
- 大数据,hadoop,spark,hive,ZooKeeper,kafka,flume等组件环境搭建
- zookeeper-kafka环境搭建,生产者消费者终端测试
- linux zookeeper 基础上搭建使用 kafka
- Flume+Kafka+Zookeeper搭建大数据日志采集框架
- golang实战使用gin+xorm搭建go语言web框架restgo详解5.7 控制器数据响应
- Go编程基础—windows下Go语言开发环境搭建
- Kafka 0.9+Zookeeper3.4.6集群搭建、配置,新Client API的使用要点,高可用性测试,以及各种坑 (转载)
- Go圣经-学习笔记之基础数据类型
- 大数据组件原理总结-Hadoop、Hbase、Kafka、Zookeeper、Spark
- Kafka 0.9+Zookeeper3.4.6集群搭建、配置,新Client API的使用要点,高可用性測试,以及各种坑
- Golang 笔记 1 基础、基本数据类型
- Go基础系列:简单数据类型
- Golang 页面模板之模板中如何插入数据,输出嵌套字段内容?以及神奇的减号“-”,如何去掉Go Template生成的标签换行符
- 网络协议栈15:网卡接收/发送数据基础知识
- 大数据_zookeeper环境搭建中的几个坑
- golang基础-WaitGroup、kafka消费者
- kafka集群搭建(使用外部zookeeper集群环境方式)
- 搭建最简单的实时数据平台kafka-->storm
- Go实战--golang中使用echo框架、MongoDB、JWT搭建REST API(labstack/echo、gopkg.in/mgo.v2、dgrijalva/jwt-go)