Merge pull request #5 from JoshKCarroll/fix-memory-leak

Fix memory leak
qntfy · Jan 29, 2019 · e54b0c3 · e54b0c3
2 parents 26590f1 + 6e124e9
commit e54b0c3
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/.travis.yml b/.travis.yml
@@ -13,7 +13,6 @@ before_install:
 # Download the dependencies
 - export GO111MODULE=on
 - go mod download
-- go mod vendor
 - go mod verify
 - go get github.com/mattn/goveralls
 - go get golang.org/x/tools/cmd/cover

diff --git a/sink.go b/sink.go
@@ -99,7 +99,7 @@ func (s *Sink) addTopicProducer(topic string) (batchproducer.Producer, error) {
 		}
 	}()
 
-	s.prods["topic"] = prod
+	s.prods[topic] = prod
 	return prod, nil
 }