kakfa从入门到放弃: golang编程操作kafka

Posted 2022-03-14 浅弋、璃鱼

文章目录

• 一、kafka代理及创建topic
• 二、生产者：
• 三、消费者：

一、kafka代理及创建topic

package amqp

import (
	"context"
	"errors"

	"project/pkg/logger"
	"github.com/Shopify/sarama"
)

const (
	prefix = "hello_" // topic前缀
)