golang操作kafka生产消息示例代码-golang代码-BFW代码库

搜索

golang操作kafka生产消息示例代码

下载在webide运行代码

代码语言：golang

所属分类：其他

代码描述：golang操作kafka生产消息示例代码

代码标签： golang 操作 kafka 生产消息示例代码

下面为部分代码预览，完整代码请点击下载或在bfwstudio webide中打开

package main

import (
	"fmt"

	"github.com/Shopify/sarama"
)

// 基于sarama第三方库开发的kafka client

func main() {
	config := sarama.NewConfig()
	config.Producer.RequiredAcks = sarama.WaitForAll          // 发送完数据需要leader和follow都确认
	config.Producer.Partitioner = sarama.NewRandomPartitioner // 新选出一个partition
	config.Producer.Return.Successes = true                   // 成功交付的消息将在success channel返回

	// 构造一个消息
	msg := &sarama.ProducerMessage{}
	msg.Topic = "test"
	msg.Value = sarama.StringEncoder.........完整代码请登录后点击上方下载按钮下载查看

网友评论0

相似代码

golang使用ip2region库实现ip地址转换成实际地址（国家省市区运营商）代码

golang实现端口转发反向代理示例代码

imaging实现golang合并多张照片成gif动态图片代码

golang实现合并多张照片成gif动态图片代码

golang使用fsnotify实现目录文件夹实时增删改监控代码

golang实现零宽字符隐写编码解码效果代码

go使用tunny实现协程池处理http请求示例代码

golang实现sm2 加密解密验签名证示例代码

golang实现sm3 hash加密示例代码

golang实现sm4加密解密示例代码

其他语言代码库

Html代码库 Python代码库 Java代码库 Php代码库 Phpcli代码库 Golang代码库 C#代码库 Nodejs代码库 C代码库 C++代码库 Sql代码库 R代码库 Rust代码库 Ruby代码库 Dart代码库 Vb代码库 D代码库 F#代码库 Typescript代码库 Coffeescript代码库 Julia代码库 Kotlin代码库 Perl代码库 Groovy代码库 Lua代码库 Vala代码库 Ocaml代码库 Assembly代码库 Objectc代码库 Scala代码库 Erlang代码库 Pascal代码库 Swift代码库 Fortran代码库 Bash代码库 Clojure代码库 Ada代码库 Elixir代码库 Cobol代码库 Haskell代码库 Nim代码库 Racket代码库 Lisp代码库