Closed tmpapageorgiou closed 7 years ago
The error message are generate intermitantly lways after call producer.Stop()
(localhost:4150) IO error - EOF
The following code reproduces the problem:
package main import ( "bitbucket.org/tpapageorgiou/mytest/broker" log "github.com/Sirupsen/logrus" "github.com/nsqio/go-nsq" ) func main() { config := nsq.NewConfig() buffer := []byte{`{"test": "123"}`} for i := 0; i < 100; i++ { producer, _ := nsq.NewProducer("localhost:4150", config) producer.SetLogger(broker.NewNSQLogrusLoggerAtLevel(log.DebugLevel)) err := producer.Publish("test_topic", buffer) if err != nil { log.Error(err) } producer.Stop() } }
I am using:
Thi is a diplicated of https://github.com/nsqio/go-nsq/issues/184
This is indeed a duplicate, but it was thought to have been fixed in #201 which was included in go-nsq v1.0.6
The error message are generate intermitantly lways after call producer.Stop()
(localhost:4150) IO error - EOF
The following code reproduces the problem:
I am using: