@ -121,7 +121,6 @@ func (w *KafkaWriter) Write(p []byte) (n int, err error) {
}
func main() {
pusher := kq.NewPusher([]string{"localhost:9092"}, "go-zero")
defer pusher.Close()