We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4a5e3d0 commit cc20f9fCopy full SHA for cc20f9f
kafka-clients/zapkafka/kafka_syncer.go
@@ -13,7 +13,7 @@ type kafkaWriteSyncer struct {
13
14
func NewKafkaAsyncProducer(addrs []string) (sarama.AsyncProducer, error) {
15
config := sarama.NewConfig()
16
- config.Consumer.Return.Errors = true
+ config.Producer.Return.Errors = true
17
return sarama.NewAsyncProducer(addrs, config)
18
}
19
0 commit comments