Use Unix() int64 time for comparing timestamps in kafka consumer

influxdata · Oct 16, 2015 · 73f1ed4 · 73f1ed4
1 parent b28b4bd
commit 73f1ed4
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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) {