diff --git a/clients/src/main/java/org/apache/kafka/common/superstream/Superstream.java b/clients/src/main/java/org/apache/kafka/common/superstream/Superstream.java
index c09cbd20..9041f595 100644
--- a/clients/src/main/java/org/apache/kafka/common/superstream/Superstream.java
+++ b/clients/src/main/java/org/apache/kafka/common/superstream/Superstream.java
@@ -424,7 +424,7 @@ public void sendClientTypeUpdateReq() {
             return;
         }
         try {
-            <String, Object> reqData = new HashMap<>();
+            Map<String, Object> reqData = new HashMap<>();
             reqData.put("client_hash", clientHash);
             reqData.put("type", type);
             ObjectMapper mapper = new ObjectMapper();