diff --git a/kafka/producer.go b/kafka/producer.go index 47bc2ee94..f1020e6c0 100644 --- a/kafka/producer.go +++ b/kafka/producer.go @@ -241,7 +241,7 @@ func (p *Producer) produce(msg *Message, msgFlags int, deliveryChan chan Event) } var timestamp int64 - if !msg.Timestamp.IsZero() { + if msg.Timestamp.IsZero() { timestamp = msg.Timestamp.UnixNano() / 1000000 }