From be3477a6013dbb6759b335f939d15431e1aa6a2b Mon Sep 17 00:00:00 2001 From: Vingurzhou Date: Fri, 14 Feb 2025 16:33:16 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8A=95=E9=80=92=E6=8A=A5=E5=91=8A=E6=97=B6?= =?UTF-8?q?=E9=97=B4=E6=88=B3=E6=98=BE=E7=A4=BA=E9=94=99=E8=AF=AF=EF=BC=8C?= =?UTF-8?q?=E4=B8=80=E7=9B=B4=E6=98=BE=E7=A4=BA=E4=B8=BA=E5=85=AC=E5=8E=86?= =?UTF-8?q?=E8=B5=B7=E7=82=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- kafka/producer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 }