当前位置:   article > 正文

Go操作Kafka_go kafka

go kafka

点击链接查看我的个人博客,文章更全更详细

sarama

Go语言中连接kafka使用第三方库: github.com/Shopify/sarama。

生产者


func sendMsg() {
   
	config := sarama.NewConfig()
	config.Producer.RequiredAcks = sarama.WaitForAll
	config.Producer.Partitione
  • 1
  • 2
  • 3
  • 4
  • 5
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/你好赵伟/article/detail/529538
推荐阅读
相关标签
  

闽ICP备14008679号