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

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