[rocketmq-clients] branch master updated: Fix the time zone to generate message id (#254)

[aa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new 2cf911c  Fix the time zone to generate message id (#254)
2cf911c is described below

commit 2cf911c74c726580efec91467265bbc67d148c4b
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Thu Sep 29 11:42:49 2022 +0800

    Fix the time zone to generate message id (#254)
---
 .../java/org/apache/rocketmq/client/java/message/MessageIdCodec.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageIdCodec.java b/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageIdCodec.java
index f126438..a2c2e40 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageIdCodec.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageIdCodec.java
@@ -20,6 +20,7 @@ package org.apache.rocketmq.client.java.message;
 import java.nio.ByteBuffer;
 import java.nio.ByteOrder;
 import java.util.Calendar;
+import java.util.TimeZone;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 import org.apache.rocketmq.client.apis.message.MessageId;
@@ -104,7 +105,7 @@ public class MessageIdCodec {
 
     private long customEpochMillis() {
         // 2021-01-01 00:00:00
-        final Calendar calendar = Calendar.getInstance();
+        final Calendar calendar = Calendar.getInstance(TimeZone.getTimeZone("Etc/UTC"));
         calendar.set(Calendar.YEAR, 2021);
         calendar.set(Calendar.MONTH, Calendar.JANUARY);
         calendar.set(Calendar.DAY_OF_MONTH, 1);