Removed unused log packagae & updated context package name to eliminate test conflict

Author: hartfordfive

tailer/kafkaTailer.go

@@ -1,8 +1,7 @@
 package tailer
 
 import (
-	"context"
-	"log"
+	ctx "context"
 	"sync"
 
 	"github.com/Shopify/sarama"
@@ -54,7 +53,7 @@ func initKafkaConsumer(lineChan chan *fswatcher.Line, errorChan chan fswatcher.E
 
 	version, err := sarama.ParseKafkaVersion(cfg.KafkaVersion)
 	if err != nil {
-		log.Panicf("[Kafka] Error parsing Kafka version: %v", err)
+		logrus.Panicf("[Kafka] Error parsing Kafka version: %v", err)
 	}
 
 	/**
@@ -90,7 +89,7 @@ func initKafkaConsumer(lineChan chan *fswatcher.Line, errorChan chan fswatcher.E
 	 * Setup a new Sarama consumer group
 	 */
 
-	ctx, cancel := context.WithCancel(context.Background())
+	ctx, cancel := ctx.WithCancel(ctx.Background())
 	client, err := sarama.NewConsumerGroup(cfg.KafkaBrokers, cfg.KafkaConsumerGroupName, kafkaConfig)
 	if err != nil {
 		consumer.errorChan <- fswatcher.NewError(fswatcher.NotSpecified, err, "[Kafka] Error creating client")