Update MCP SDK version and other stuff with that

Signed-off-by: see-quick <maros.orsak159@gmail.com>

Author: see-quick

dependency-reduced-pom.xml

@@ -42,7 +42,7 @@
     </plugins>
   </build>
   <properties>
-    <mcp-sdk.version>0.10.0</mcp-sdk.version>
+    <mcp-sdk.version>0.14.0</mcp-sdk.version>
     <maven.compiler.source>21</maven.compiler.source>
     <fabric8.version>7.5.1</fabric8.version>
     <strimzi.version>0.49.1</strimzi.version>

pom.xml

@@ -17,7 +17,7 @@
         <maven.compiler.target>21</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 
-        <mcp-sdk.version>0.10.0</mcp-sdk.version>
+        <mcp-sdk.version>0.14.0</mcp-sdk.version>
         <fabric8.version>7.5.1</fabric8.version>
         <strimzi.version>0.49.1</strimzi.version>
         <slf4j.version>2.0.17</slf4j.version>

src/main/java/io/seequick/mcp/StrimziMcpServer.java

@@ -3,6 +3,7 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import io.fabric8.kubernetes.client.KubernetesClient;
 import io.fabric8.kubernetes.client.KubernetesClientBuilder;
+import io.modelcontextprotocol.json.jackson.JacksonMcpJsonMapper;
 import io.modelcontextprotocol.server.McpServer;
 import io.modelcontextprotocol.server.McpSyncServer;
 import io.modelcontextprotocol.server.transport.StdioServerTransportProvider;
@@ -108,7 +109,7 @@ private List<StrimziTool> createTools() {
      * Starts the MCP server with stdio transport.
      */
     public void start() {
-        StdioServerTransportProvider transportProvider = new StdioServerTransportProvider(new ObjectMapper());
+        StdioServerTransportProvider transportProvider = new StdioServerTransportProvider(new JacksonMcpJsonMapper(new ObjectMapper()));
 
         McpSyncServer syncServer = McpServer.sync(transportProvider)
                 .serverInfo(SERVER_NAME, SERVER_VERSION)

src/main/java/io/seequick/mcp/tool/AbstractStrimziTool.java

@@ -1,9 +1,11 @@
 package io.seequick.mcp.tool;
 
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import io.fabric8.kubernetes.client.KubernetesClient;
 import io.modelcontextprotocol.server.McpServerFeatures;
-import io.modelcontextprotocol.server.McpSyncServerExchange;
 import io.modelcontextprotocol.spec.McpSchema.CallToolResult;
+import io.modelcontextprotocol.spec.McpSchema.JsonSchema;
 import io.modelcontextprotocol.spec.McpSchema.TextContent;
 import io.modelcontextprotocol.spec.McpSchema.Tool;
 
@@ -15,6 +17,8 @@
  */
 public abstract class AbstractStrimziTool implements StrimziTool {
 
+    private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
+
     protected final KubernetesClient kubernetesClient;
 
     protected AbstractStrimziTool(KubernetesClient kubernetesClient) {
@@ -34,17 +38,50 @@ protected AbstractStrimziTool(KubernetesClient kubernetesClient) {
     /**
      * Returns the JSON schema for the tool's input parameters.
      */
-    protected abstract String getInputSchema();
+    protected abstract JsonSchema getInputSchema();
 
     /**
      * Executes the tool with the given arguments.
      */
     protected abstract CallToolResult execute(Map<String, Object> args);
 
+    /**
+     * Parses a JSON schema string into a JsonSchema object.
+     */
+    @SuppressWarnings("unchecked")
+    protected static JsonSchema parseSchema(String jsonSchema) {
+        try {
+            Map<String, Object> schemaMap = OBJECT_MAPPER.readValue(
+                jsonSchema, new TypeReference<>() {});
+
+            String type = (String) schemaMap.get("type");
+            Map<String, Object> properties = (Map<String, Object>) schemaMap.get("properties");
+            List<String> required = (List<String>) schemaMap.get("required");
+            Boolean additionalProperties = schemaMap.get("additionalProperties") instanceof Boolean b ? b : null;
+            Map<String, Object> defs = (Map<String, Object>) schemaMap.get("$defs");
+            Map<String, Object> definitions = (Map<String, Object>) schemaMap.get("definitions");
+
+            return new JsonSchema(
+                type,
+            properties,
+                required,
+                additionalProperties,
+                defs,
+                definitions
+            );
+        } catch (Exception e) {
+            throw new RuntimeException("Failed to parse JSON schema: " + e.getMessage(), e);
+        }
+    }
+
     @Override
     public McpServerFeatures.SyncToolSpecification getSpecification() {
         return new McpServerFeatures.SyncToolSpecification(
-                new Tool(getName(), getDescription(), getInputSchema()),
+            Tool.builder()
+                .name(getName())
+                .description(getDescription())
+                .inputSchema(getInputSchema())
+                .build(),
                 (exchange, args) -> execute(args)
         );
     }

src/main/java/io/seequick/mcp/tool/cluster/DescribeBridgeTool.java

@@ -2,6 +2,7 @@
 
 import io.fabric8.kubernetes.client.KubernetesClient;
 import io.modelcontextprotocol.spec.McpSchema.CallToolResult;
+import io.modelcontextprotocol.spec.McpSchema.JsonSchema;
 import io.strimzi.api.kafka.model.bridge.KafkaBridge;
 import io.strimzi.api.kafka.model.bridge.KafkaBridgeList;
 import io.seequick.mcp.tool.AbstractStrimziTool;
@@ -45,8 +46,8 @@ protected String getDescription() {
     }
 
     @Override
-    protected String getInputSchema() {
-        return SCHEMA;
+    protected JsonSchema getInputSchema() {
+        return parseSchema(SCHEMA);
     }
 
     @Override

src/main/java/io/seequick/mcp/tool/cluster/DescribeConnectorTool.java

@@ -2,6 +2,7 @@
 
 import io.fabric8.kubernetes.client.KubernetesClient;
 import io.modelcontextprotocol.spec.McpSchema.CallToolResult;
+import io.modelcontextprotocol.spec.McpSchema.JsonSchema;
 import io.strimzi.api.kafka.model.connector.KafkaConnector;
 import io.strimzi.api.kafka.model.connector.KafkaConnectorList;
 import io.seequick.mcp.tool.AbstractStrimziTool;
@@ -46,8 +47,8 @@ protected String getDescription() {
     }
 
     @Override
-    protected String getInputSchema() {
-        return SCHEMA;
+    protected JsonSchema getInputSchema() {
+        return parseSchema(SCHEMA);
     }
 
     @Override

src/main/java/io/seequick/mcp/tool/cluster/DescribeKafkaConnectTool.java

@@ -2,6 +2,7 @@
 
 import io.fabric8.kubernetes.client.KubernetesClient;
 import io.modelcontextprotocol.spec.McpSchema.CallToolResult;
+import io.modelcontextprotocol.spec.McpSchema.JsonSchema;
 import io.strimzi.api.kafka.model.connect.KafkaConnect;
 import io.strimzi.api.kafka.model.connect.KafkaConnectList;
 import io.seequick.mcp.tool.AbstractStrimziTool;
@@ -45,8 +46,8 @@ protected String getDescription() {
     }
 
     @Override
-    protected String getInputSchema() {
-        return SCHEMA;
+    protected JsonSchema getInputSchema() {
+        return parseSchema(SCHEMA);
     }
 
     @Override

src/main/java/io/seequick/mcp/tool/cluster/DescribeMirrorMaker2Tool.java

@@ -2,6 +2,7 @@
 
 import io.fabric8.kubernetes.client.KubernetesClient;
 import io.modelcontextprotocol.spec.McpSchema.CallToolResult;
+import io.modelcontextprotocol.spec.McpSchema.JsonSchema;
 import io.strimzi.api.kafka.model.mirrormaker2.KafkaMirrorMaker2;
 import io.strimzi.api.kafka.model.mirrormaker2.KafkaMirrorMaker2List;
 import io.seequick.mcp.tool.AbstractStrimziTool;
@@ -45,8 +46,8 @@ protected String getDescription() {
     }
 
     @Override
-    protected String getInputSchema() {
-        return SCHEMA;
+    protected JsonSchema getInputSchema() {
+        return parseSchema(SCHEMA);
     }
 
     @Override

src/main/java/io/seequick/mcp/tool/cluster/DescribeNodePoolTool.java

@@ -2,6 +2,7 @@
 
 import io.fabric8.kubernetes.client.KubernetesClient;
 import io.modelcontextprotocol.spec.McpSchema.CallToolResult;
+import io.modelcontextprotocol.spec.McpSchema.JsonSchema;
 import io.strimzi.api.kafka.model.nodepool.KafkaNodePool;
 import io.strimzi.api.kafka.model.nodepool.KafkaNodePoolList;
 import io.seequick.mcp.tool.AbstractStrimziTool;
@@ -45,8 +46,8 @@ protected String getDescription() {
     }
 
     @Override
-    protected String getInputSchema() {
-        return SCHEMA;
+    protected JsonSchema getInputSchema() {
+        return parseSchema(SCHEMA);
     }
 
     @Override

src/main/java/io/seequick/mcp/tool/cluster/DescribeRebalanceTool.java

@@ -2,6 +2,7 @@
 
 import io.fabric8.kubernetes.client.KubernetesClient;
 import io.modelcontextprotocol.spec.McpSchema.CallToolResult;
+import io.modelcontextprotocol.spec.McpSchema.JsonSchema;
 import io.strimzi.api.kafka.model.rebalance.KafkaRebalance;
 import io.strimzi.api.kafka.model.rebalance.KafkaRebalanceList;
 import io.seequick.mcp.tool.AbstractStrimziTool;
@@ -45,8 +46,8 @@ protected String getDescription() {
     }
 
     @Override
-    protected String getInputSchema() {
-        return SCHEMA;
+    protected JsonSchema getInputSchema() {
+        return parseSchema(SCHEMA);
     }
 
     @Override