diff --git a/Gopkg.toml b/Gopkg.toml
index e4b6dae..b7f46a1 100644
--- a/Gopkg.toml
+++ b/Gopkg.toml
@@ -38,7 +38,7 @@
   version = "0.8.0"
 
 [[constraint]]
-  name = "gopkg.in/Shopify/sarama.v1"
+  name = "github.com/Shopify/sarama"
   version = "1.19.0"
 
 [prune]
diff --git a/goflow.go b/goflow.go
index bb915d2..95e3f29 100644
--- a/goflow.go
+++ b/goflow.go
@@ -28,7 +28,7 @@ import (
 	"bytes"
 )
 
-const AppVersion = "GoFlow v2.0.6"
+const AppVersion = "GoFlow v2.0.7"
 
 var (
 	FEnable = flag.Bool("netflow", true, "Enable NetFlow")
diff --git a/transport/kafka.go b/transport/kafka.go
index 448d156..bc09e65 100644
--- a/transport/kafka.go
+++ b/transport/kafka.go
@@ -6,7 +6,7 @@ import (
 	log "github.com/Sirupsen/logrus"
 	flowmessage "github.com/cloudflare/goflow/pb"
 	proto "github.com/golang/protobuf/proto"
-	sarama "gopkg.in/Shopify/sarama.v1"
+	sarama "github.com/Shopify/sarama"
 	"os"
 )