diff --git a/common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java b/common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java
index 6de0b69fb75a..94494a061197 100644
--- a/common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java
+++ b/common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java
@@ -388,18 +388,18 @@ public static MessageExt decode(
     }
 
     public static MessageExt decode(
-        java.nio.ByteBuffer byteBuffer, final boolean readBody, final boolean deCompressBody, final boolean isClient) {
+        ByteBuffer byteBuffer, final boolean readBody, final boolean deCompressBody, final boolean isClient) {
         return decode(byteBuffer, readBody, deCompressBody, isClient, false, false);
     }
 
     public static MessageExt decode(
-        java.nio.ByteBuffer byteBuffer, final boolean readBody, final boolean deCompressBody, final boolean isClient,
+        ByteBuffer byteBuffer, final boolean readBody, final boolean deCompressBody, final boolean isClient,
         final boolean isSetPropertiesString) {
         return decode(byteBuffer, readBody, deCompressBody, isClient, isSetPropertiesString, false);
     }
 
     public static MessageExt decode(
-        java.nio.ByteBuffer byteBuffer, final boolean readBody, final boolean deCompressBody, final boolean isClient,
+        ByteBuffer byteBuffer, final boolean readBody, final boolean deCompressBody, final boolean isClient,
         final boolean isSetPropertiesString, final boolean checkCRC) {
         try {
 
diff --git a/common/src/main/java/org/apache/rocketmq/common/message/MessageVersion.java b/common/src/main/java/org/apache/rocketmq/common/message/MessageVersion.java
index bb1c2e8d64bc..479a50e5eb22 100644
--- a/common/src/main/java/org/apache/rocketmq/common/message/MessageVersion.java
+++ b/common/src/main/java/org/apache/rocketmq/common/message/MessageVersion.java
@@ -86,7 +86,7 @@ public int getMagicCode() {
 
     public abstract int getTopicLengthSize();
 
-    public abstract int getTopicLength(java.nio.ByteBuffer buffer);
-    public abstract int getTopicLength(java.nio.ByteBuffer buffer, int index);
-    public abstract void putTopicLength(java.nio.ByteBuffer buffer, int topicLength);
+    public abstract int getTopicLength(ByteBuffer buffer);
+    public abstract int getTopicLength(ByteBuffer buffer, int index);
+    public abstract void putTopicLength(ByteBuffer buffer, int topicLength);
 }
diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
index e6ee3bacc154..6c862e5dadae 100644
--- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -387,7 +387,7 @@ else if (!dispatchRequest.isSuccess()) {
         }
     }
 
-    public DispatchRequest checkMessageAndReturnSize(java.nio.ByteBuffer byteBuffer, final boolean checkCRC,
+    public DispatchRequest checkMessageAndReturnSize(ByteBuffer byteBuffer, final boolean checkCRC,
         final boolean checkDupInfo) {
         return this.checkMessageAndReturnSize(byteBuffer, checkCRC, checkDupInfo, true);
     }
@@ -403,7 +403,7 @@ private void doNothingForDeadCode(final Object obj) {
      *
      * @return 0 Come the end of the file // >0 Normal messages // -1 Message checksum failure
      */
-    public DispatchRequest checkMessageAndReturnSize(java.nio.ByteBuffer byteBuffer, final boolean checkCRC,
+    public DispatchRequest checkMessageAndReturnSize(ByteBuffer byteBuffer, final boolean checkCRC,
         final boolean checkDupInfo, final boolean readBody) {
         try {
             // 1 TOTAL SIZE