kakfa从入门到放弃(二): golang编程 *** 作kafka

文章目录 一、kafka代理及创建topic 二、生产者： 三、消费者：

一、kafka代理及创建topic

package amqp

import (
	"context"
	"errors"

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

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