- 一、kafka代理及创建topic
- 二、生产者:
- 三、消费者:
package amqp import ( "context" "errors" "project/pkg/logger" "github.com/Shopify/sarama" ) const ( prefix = "hello_" // topic前缀 )

package amqp import ( "context" "errors" "project/pkg/logger" "github.com/Shopify/sarama" ) const ( prefix = "hello_" // topic前缀 )