get_topic_broker_configs
Retrieve Kafka broker configuration details for a specific topic to manage and optimize data streaming across clusters.
Instructions
Get broker configurations for a topic.
Args: environment: The environment name. topic_name: Name of the topic.
Returns: List of broker configuration details.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment | Yes | ||
| topic_name | Yes |
Output Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| result | Yes |
Implementation Reference
- src/lenses_mcp/tools/topics.py:177-190 (handler)The main handler function for the 'get_topic_broker_configs' tool. It is decorated with @mcp.tool() which handles registration. Makes a GET request to retrieve broker configurations for the specified topic.
@mcp.tool() async def get_topic_broker_configs(environment: str, topic_name: str) -> List[Dict[str, Any]]: """ Get broker configurations for a topic. Args: environment: The environment name. topic_name: Name of the topic. Returns: List of broker configuration details. """ endpoint = f"/api/v1/environments/{environment}/proxy/api/topics/{topic_name}/brokerConfigs" return await api_client._make_request("GET", endpoint) - src/lenses_mcp/server.py:33-33 (registration)Calls register_topics(mcp) which defines and registers the get_topic_broker_configs tool among others.
register_topics(mcp)