浏览代码

Fix config for calling NewSyncProducer()

verifyProducerConfig() will check the config. https://github.com/Shopify/sarama/commit/f0062da5ae1a62f7841e563a244e11a5ad9b96d7#diff-9aea0c6326a7f3fb0c000fabf28b3d22R82
mingang.he 8 年之前
父节点
当前提交
bcc8fb3014
共有 1 个文件被更改,包括 1 次插入0 次删除
  1. 1 0
      tools/kafka-console-producer/kafka-console-producer.go

+ 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 "":