From 73f1ed4f2560f5d0fc3269b1fc9293230f10f652 Mon Sep 17 00:00:00 2001
From: Cameron Sparr <cameronsparr@gmail.com>
Date: Fri, 16 Oct 2015 16:58:52 -0600
Subject: [PATCH] Use Unix() int64 time for comparing timestamps in kafka
 consumer

---
 plugins/kafka_consumer/kafka_consumer_test.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/plugins/kafka_consumer/kafka_consumer_test.go b/plugins/kafka_consumer/kafka_consumer_test.go
index 3b697282d..0385f54be 100644
--- a/plugins/kafka_consumer/kafka_consumer_test.go
+++ b/plugins/kafka_consumer/kafka_consumer_test.go
@@ -71,7 +71,11 @@ func TestEmitMetricsSendMetricsToAcc(t *testing.T) {
 		"region":    "us-west",
 	}, point.Tags)
 
-	assert.Equal(t, time.Unix(0, 1422568543702900257), point.Time)
+	if time.Unix(0, 1422568543702900257).Unix() != point.Time.Unix() {
+		t.Errorf("Expected: %v, received %v\n",
+			time.Unix(0, 1422568543702900257).Unix(),
+			point.Time.Unix())
+	}
 }
 
 func TestEmitMetricsTimesOut(t *testing.T) {