golang操作kafka
生产者producer.gopackage mainimport ("fmt" "github.com/Shopify/sarama")func main() { fmt.Printf("producer_test\n") config := sarama.NewConfig() config.Producer.RequiredAcks = sarama.WaitForAll...
