Browse Source

Merge pull request #796 from doubleceston/patch-1

add config setting
Evan Huus 9 years ago
parent
commit
9a9e66f928
1 changed files with 1 additions and 0 deletions
  1. 1 0
      examples/http_server/http_server.go

+ 1 - 0
examples/http_server/http_server.go

@@ -196,6 +196,7 @@ func newDataCollector(brokerList []string) sarama.SyncProducer {
 	config := sarama.NewConfig()
 	config.Producer.RequiredAcks = sarama.WaitForAll // Wait for all in-sync replicas to ack the message
 	config.Producer.Retry.Max = 10                   // Retry up to 10 times to produce the message
+	config.Producer.Return.Successes = true
 	tlsConfig := createTlsConfiguration()
 	if tlsConfig != nil {
 		config.Net.TLS.Config = tlsConfig