String uniqueId = UUID.randomUUID().toString(); Message message = new Message("topic", "tag", uniqueId, "Hello RocketMQ".getBytes()); String uniqueId = message.getKeys(); if (!isIdempotent(uniqueId)) { processMessage(message); markAsProcessed(uniqueId); } else { ignoreMessage(message); }