Fix for issue #93, explicitly call sarama.v1 -> sarama

influxdata · Aug 6, 2015 · 756377f · 756377f
1 parent ab28707
commit 756377f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/plugins/kafka_consumer/kafka_consumer.go b/plugins/kafka_consumer/kafka_consumer.go
@@ -5,10 +5,10 @@ import (
 	"os/signal"
 	"time"
 
+	"github.com/Shopify/sarama"
 	"github.com/influxdb/influxdb/tsdb"
 	"github.com/influxdb/telegraf/plugins"
 	"github.com/wvanbergen/kafka/consumergroup"
-	"gopkg.in/Shopify/sarama.v1"
 )
 
 type Kafka struct {

diff --git a/plugins/kafka_consumer/kafka_consumer_test.go b/plugins/kafka_consumer/kafka_consumer_test.go
@@ -5,10 +5,10 @@ import (
 	"testing"
 	"time"
 
+	"github.com/Shopify/sarama"
 	"github.com/influxdb/telegraf/testutil"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
-	"gopkg.in/Shopify/sarama.v1"
 )
 
 const testMsg = "cpu_load_short,direction=in,host=server01,region=us-west value=23422.0 1422568543702900257"