mcp-confluent

Instructions

Implementation Reference

• src/confluent/tools/handlers/kafka/list-topics-handler.ts:15-36 (handler)

  ListTopicsHandler class that extends BaseToolHandler. The handle() method lists all Kafka topics using the admin client and returns a formatted string response. Also defines tool config including schema and required env vars.

  export class ListTopicsHandler extends BaseToolHandler {
    async handle(
      clientManager: ClientManager,
      // eslint-disable-next-line @typescript-eslint/no-unused-vars
      toolArguments: Record<string, unknown>,
    ): Promise<CallToolResult> {
      const topics = await (await clientManager.getAdminClient()).listTopics();
      return this.createResponse(`Kafka topics: ${topics.join(",")}`);
    }
  
    getToolConfig(): ToolConfig {
      return {
        name: ToolName.LIST_TOPICS,
        description: "List all topics in the Kafka cluster.",
        inputSchema: listTopicArgs.shape,
      };
    }
  
    getRequiredEnvVars(): EnvVar[] {
      return ["KAFKA_API_KEY", "KAFKA_API_SECRET", "BOOTSTRAP_SERVERS"];
    }
  }

• src/confluent/tools/handlers/kafka/list-topics-handler.ts:11-13 (schema)

  Zod schema for tool input arguments, which requires no parameters.

  const listTopicArgs = z.object({
    // No arguments
  });

• src/confluent/tools/tool-factory.ts:43-43 (registration)

  Registration of the ListTopicsHandler instance in the ToolFactory's static handlers Map, keyed by ToolName.LIST_TOPICS.

  [ToolName.LIST_TOPICS, new ListTopicsHandler()],

• src/confluent/tools/tool-name.ts:2-2 (helper)

  Enum definition for the tool name 'list-topics' used in registration and tool config.

  LIST_TOPICS = "list-topics",