代码语言:golang
所属分类:其他
代码描述:golang操作kafka消费消息示例代码
代码标签:
golang
操作
kafka
消费
消息
示例
代码
下面为部分代码预览,完整代码请点击下载或在bfwstudio webide中打开
package main
import (
"fmt"
"github.com/Shopify/sarama"
)
func main() {
config := sarama.NewConfig()
config.Consumer.Return.Errors = true
// .........完整代码请登录后点击上方下载按钮下载查看
网友评论0