Merge pull request #93 from utilitywarehouse/cluster-fork

consume sarama cluster fork
utilitywarehouse · Nov 25, 2019 · 107e36a · 107e36a
2 parents cdb8f20 + dfee783
commit 107e36a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/kafkasource.go b/kafka/kafkasource.go
@@ -5,7 +5,7 @@ import (
 	"time"
 
 	"github.com/Shopify/sarama"
-	"github.com/bsm/sarama-cluster"
+	"github.com/utilitywarehouse/sarama-cluster"
 	"github.com/utilitywarehouse/go-pubsub"
 	"golang.org/x/sync/errgroup"
 )