From 756377f06de02b3b14eca62bcba7c6abd07d4af5 Mon Sep 17 00:00:00 2001 From: Cameron Sparr Date: Thu, 6 Aug 2015 10:35:50 -0600 Subject: [PATCH] Fix for issue #93, explicitly call sarama.v1 -> sarama --- plugins/kafka_consumer/kafka_consumer.go | 2 +- plugins/kafka_consumer/kafka_consumer_test.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/plugins/kafka_consumer/kafka_consumer.go b/plugins/kafka_consumer/kafka_consumer.go index 5e1b7fc5bca66..b2836e1d89518 100644 --- 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 index fa6ad4a973f87..3b697282d74d3 100644 --- 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"