Add tool to get bootstrap server addresses (#7)

Signed-off-by: David Kornel <kornys@outlook.com>

Author: kornys

README.md

@@ -111,6 +111,7 @@ All tools support **smart discovery** - if you don't specify a namespace, they a
 - **`strimzi_kafka_clusters`** - Discover and list all Kafka clusters
 - **`strimzi_cluster_pods`** - Get cluster pod status and health
 - **`strimzi_kafka_topics`** - Get topic configuration and status
+- **`strimzi_bootstrap_servers`** - Get Kafka bootstrap servers for client connections
 - **`strimzi_operator_status`** - Check operator deployment health
 - **`strimzi_operator_logs`** - Get operator logs with error analysis
 

src/main/java/io/strimzi/mcp/mcp/StrimziOperatorMcpTools.java

@@ -120,4 +120,24 @@ public Object getKafkaTopics(
             return ToolError.of("Failed to retrieve Kafka topics", e);
         }
     }
+
+    @Tool(
+        name = "strimzi_bootstrap_servers",
+        description = "Get Kafka bootstrap servers (connection endpoints) from Kafka Custom Resource. " +
+                     "Extracts all available listener addresses and ports for client connections. " +
+                     "Returns bootstrap server URLs for internal, external, and other configured listeners. " +
+                     "Smart discovery: If namespace not specified, automatically searches for Strimzi installations."
+    )
+    public Object getBootstrapServers(
+        @ToolArg(description = "Namespace of the Kafka cluster (optional - auto-discovered if not specified)")
+        String namespace,
+        @ToolArg(description = "Name of the Kafka cluster to query (required, e.g., 'my-cluster')")
+        String clusterName
+    ) {
+        try {
+            return clusterService.getBootstrapServers(namespace, clusterName);
+        } catch (Exception e) {
+            return ToolError.of("Failed to get bootstrap servers", e);
+        }
+    }
 }

src/main/java/io/strimzi/mcp/service/KafkaClusterService.java

@@ -3,6 +3,9 @@
 import io.fabric8.kubernetes.api.model.ContainerStatus;
 import io.fabric8.kubernetes.api.model.Pod;
 import io.fabric8.kubernetes.client.KubernetesClient;
+import io.strimzi.api.kafka.model.kafka.Kafka;
+import io.strimzi.mcp.dto.BootstrapServersResult;
+import io.strimzi.mcp.dto.BootstrapServersResult.BootstrapServerInfo;
 import io.strimzi.mcp.dto.ClusterPodsResult;
 import io.strimzi.mcp.dto.KafkaClustersResult;
 import io.strimzi.mcp.service.StrimziDiscoveryService.KafkaClusterInfo;
@@ -234,4 +237,95 @@ private Map<String, Integer> calculateComponentBreakdown(List<ClusterPodsResult.
                 Collectors.collectingAndThen(Collectors.counting(), Math::toIntExact)
             ));
     }
+
+    /**
+     * Get bootstrap servers for a Kafka cluster from its Custom Resource.
+     */
+    public BootstrapServersResult getBootstrapServers(String namespace, String clusterName) {
+        String normalizedNamespace = discoveryService.normalizeNamespace(namespace);
+        String normalizedClusterName = discoveryService.normalizeClusterName(clusterName);
+
+        // Auto-discover namespace if not specified
+        if (normalizedNamespace == null) {
+            List<String> discoveredNamespaces = discoveryService.discoverStrimziNamespaces();
+            if (discoveredNamespaces.size() == 1) {
+                normalizedNamespace = discoveredNamespaces.get(0);
+                LOG.infof("Auto-discovered Strimzi in namespace: %s", normalizedNamespace);
+            } else if (!discoveredNamespaces.isEmpty()) {
+                String namespaceList = String.join(", ", discoveredNamespaces);
+                return BootstrapServersResult.error(null, normalizedClusterName,
+                    String.format("Found Strimzi in multiple namespaces: %s. " +
+                        "Please specify: 'Get bootstrap servers for %s in the %s namespace'",
+                        namespaceList, normalizedClusterName, discoveredNamespaces.get(0)));
+            } else {
+                return BootstrapServersResult.error(null, normalizedClusterName,
+                    "No Strimzi installation found. Please ensure Kafka is deployed.");
+            }
+        }
+
+        if (normalizedClusterName == null) {
+            return BootstrapServersResult.error(normalizedNamespace, null,
+                "Cluster name is required. Please specify a cluster name like 'my-cluster'");
+        }
+
+        LOG.infof("KafkaClusterService: getBootstrapServers (namespace=%s, cluster=%s)",
+                 normalizedNamespace, normalizedClusterName);
+
+        try {
+            Kafka kafka = kubernetesClient.resources(Kafka.class)
+                .inNamespace(normalizedNamespace)
+                .withName(normalizedClusterName)
+                .get();
+
+            if (kafka == null) {
+                return BootstrapServersResult.notFound(normalizedNamespace, normalizedClusterName);
+            }
+
+            List<BootstrapServerInfo> bootstrapServers = extractBootstrapServers(kafka);
+
+            if (bootstrapServers.isEmpty()) {
+                return BootstrapServersResult.empty(normalizedNamespace, normalizedClusterName);
+            }
+
+            return BootstrapServersResult.of(normalizedNamespace, normalizedClusterName, bootstrapServers);
+
+        } catch (Exception e) {
+            LOG.errorf(e, "Error retrieving bootstrap servers for cluster %s in namespace %s",
+                      normalizedClusterName, normalizedNamespace);
+            return BootstrapServersResult.error(normalizedNamespace, normalizedClusterName, e.getMessage());
+        }
+    }
+
+    private List<BootstrapServerInfo> extractBootstrapServers(Kafka kafka) {
+        List<BootstrapServerInfo> servers = new ArrayList<>();
+
+        if (kafka.getStatus() == null || kafka.getStatus().getListeners() == null) {
+            return servers;
+        }
+
+        // Extract from listeners status
+        kafka.getStatus().getListeners().forEach(listener -> {
+            String listenerName = listener.getName();
+            String listenerType = listener.getType();
+
+            if (listener.getAddresses() != null) {
+                listener.getAddresses().forEach(address -> {
+                    String host = address.getHost();
+                    Integer port = address.getPort();
+
+                    if (host != null && port != null) {
+                        servers.add(new BootstrapServerInfo(
+                            host,
+                            port,
+                            listenerName,
+                            listenerType,
+                            String.format("%s:%d", host, port)
+                        ));
+                    }
+                });
+            }
+        });
+
+        return servers;
+    }
 }

src/main/java/io/strimzi/mcp/tool/StrimziOperatorTools.java

@@ -114,4 +114,23 @@ public KafkaClustersResult getKafkaClusters(String namespace) {
     public KafkaTopicsResult getKafkaTopics(String namespace, String clusterName) {
         return topicService.getKafkaTopics(namespace, clusterName);
     }
+
+    /**
+     * Get Kafka bootstrap servers (connection endpoints) from Kafka Custom Resource.
+     *
+     * Extracts all available listener addresses and ports for client connections from
+     * the Kafka Custom Resource status. Returns bootstrap server URLs for internal,
+     * external, and other configured listeners that clients can use to connect.
+     *
+     * Smart discovery: If namespace not specified, automatically searches for
+     * Strimzi installations across all namespaces.
+     *
+     * @param namespace namespace of the Kafka cluster (optional - auto-discovered if not specified)
+     * @param clusterName name of the Kafka cluster to query (required, e.g., 'my-cluster')
+     * @return structured result with bootstrap server endpoints, listeners, and connection details
+     */
+    @Tool("Get Kafka bootstrap servers for client connections. Extracts listener endpoints from Kafka Custom Resource.")
+    public BootstrapServersResult getBootstrapServers(String namespace, String clusterName) {
+        return clusterService.getBootstrapServers(namespace, clusterName);
+    }
 }