Golang 与Python 连接kafka

1. 安装

编程Producer 连接

Python 编程                                                      Golang编程

from kafka import KafkaProducer
import github.com/confluentinc/confluent-kafka-go/kafka
p = KafkaProducer(
p,err := kafka.NewProducer(&kafka.ConfigMap{
bootstrap_servers="master:9092"
"bootstrap.servers": "master"
)
})

Producer发送消息:

     Python编程                                                               Golang编程(异步发送)

msg = "send msg"
msg := "send msg"
topic = "job"
topic := "job"
p.send(topic, msg)
diverchan := make(chan kafka.Event)
p.Produce(&kafka.Message{
TopicPartition: kafka.TopicPartition{
Topic: &topic,
Partition:kafka.PartitionAny
},
Value: []byte(msg)
}, diverchan)
e := <- diverchan
et := e.(*kafka.Message)
if et.TopicPartition.Error == nil {
"send successfully"
}
close(diverchan)

Consumer编程:

   Python编程                                                                      Golang编程

from kafka import KafkaConsumer
c,er:=kafka.NewConsumer(&kafka.ConfigMap{
c = KafkaConsumer("job",
"bootstrap.servers": "master",
bootstrap_servers=["master:9092"]
"auto.offset.reset": "earliest"
)
})
for msg in c:
c.SubcribeTopics([]string{"job"},nil)
print msg
while true:
data := c.ReadMessage(-1)
print data
c.Close()

最后

以上就是负责保温杯为你收集整理的Golang 与Python 连接kafka的全部内容，希望文章能够帮你解决Golang 与Python 连接kafka所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。