Przeglądaj źródła

Merge pull request #799 from hmgle/fix-config

Fix config for calling NewSyncProducer()
Evan Huus 9 lat temu
rodzic
commit
9418d7c718

+ 1 - 0
tools/kafka-console-producer/kafka-console-producer.go

@@ -43,6 +43,7 @@ func main() {
 
 	config := sarama.NewConfig()
 	config.Producer.RequiredAcks = sarama.WaitForAll
+	config.Producer.Return.Successes = true
 
 	switch *partitioner {
 	case "":