I use github.com/segmentio/kafka-go
to publish message to kafka and meet write fail:Kafka write(1/1),errors: [kafka. (*Client).Produce: fetch request error: topic partition has no leader
.
This is my client config
p.Writer = &kafka.Writer{
Addr: kafka.TCP(addrList...),
Topic: topic,
Balancer: &kafka.LeastBytes{},
}
Anyone have meet this question or some suggestion for me?