Fix: Set current time instead of epoch 0(1970-01-01T00:00:00) in kafka message metadata

Author: prdpx7

output_kafka.go

@@ -2,12 +2,13 @@ package goreplay
 
 import (
 	"encoding/json"
-	"github.com/buger/goreplay/internal/byteutils"
-	"github.com/buger/goreplay/proto"
 	"log"
 	"strings"
 	"time"
 
+	"github.com/buger/goreplay/internal/byteutils"
+	"github.com/buger/goreplay/proto"
+
 	"github.com/Shopify/sarama"
 	"github.com/Shopify/sarama/mocks"
 )
@@ -91,8 +92,9 @@ func (o *KafkaOutput) PluginWrite(msg *Message) (n int, err error) {
 	}
 
 	o.producer.Input() <- &sarama.ProducerMessage{
-		Topic: o.config.Topic,
-		Value: message,
+		Topic:     o.config.Topic,
+		Value:     message,
+		Timestamp: time.Now(),
 	}
 
 	return len(message), nil