标签:err sarama zookeeper kafka 初识 使用 config properties
目录
kafka的使用:
修改配置文件
zookeeper.properties文件
server.properties文件
启动zookeeper
在kafka文件下启动命令窗口
输入:
.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
启动kafka
输入:
bin\windows\kafka-server-start.bat config\server.properties
启动类:
配置kafka
package main
import (
"fmt"
"github.com/Shopify/sarama"
)
func main() {
//1. 生产者配置
config := sarama.NewConfig()
config.Producer.RequiredAcks = sarama.WaitForAll //ACK
config.Producer.Partitioner = sarama.NewRandomPartitioner //分区
config.Producer.Return.Successes = true //确认
//2.连接kafka
client, err := sarama.NewSyncProducer([]string{"127.0.0.1:9092"}, config)
if err != nil {
fmt.Println("producer closed,err:", err)
return
}
defer client.Close()
//3. 封装消息
msg := &sarama.ProducerMessage{}
msg.Topic = "shopping"
msg.Value = sarama.StringEncoder("happy aaaa")
//4.发送消息
pid, offset, err := client.SendMessage(msg)
if err != nil {
fmt.Println("send msg failed,err:", err)
return
}
fmt.Printf("pid : %v offset : %v", pid, offset)
}
启动消费者
bin\windows\kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --topic shopping --from-beginning
shopping是Topic的值
标签:err,sarama,zookeeper,kafka,初识,使用,config,properties 来源: https://blog.csdn.net/qq_53267860/article/details/123075893
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。