Skip to main content
Glama

consume_messages

Consume messages from a Kafka topic with configurable offset (earliest, latest, or specific integer) and timeout, returning messages up to a set limit.

Instructions

Consumes messages from a topic. offset_spec: 'earliest', 'latest', or specific integer offset. timeout: seconds to wait for messages.

Input Schema

TableJSON Schema
NameRequiredDescriptionDefault
topic_nameYes
partitionNo
offset_specNolatest
limitNo
timeoutNo

Output Schema

TableJSON Schema
NameRequiredDescriptionDefault
resultYes
Behavior2/5

Does the description disclose side effects, auth requirements, rate limits, or destructive behavior?

No annotations provided; description only mentions offset_spec and timeout but omits side effects like offset advancement, commit behavior, or blocking nature.

Agents need to know what a tool does to the world before calling it. Descriptions should go beyond structured annotations to explain consequences.

Conciseness4/5

Is the description appropriately sized, front-loaded, and free of redundancy?

Two sentences, front-loaded with purpose, then parameter details. Efficient but could be more structured with one line per parameter.

Shorter descriptions cost fewer tokens and are easier for agents to parse. Every sentence should earn its place.

Completeness3/5

Given the tool's complexity, does the description cover enough for an agent to succeed on first attempt?

Tool has 5 parameters and no annotations; description covers 2 parameters partially. Output schema exists but doesn't excuse missing parameter context. Adequate but not thorough.

Complex tools with many parameters or behaviors need more documentation. Simple tools need less. This dimension scales expectations accordingly.

Parameters2/5

Does the description clarify parameter syntax, constraints, interactions, or defaults beyond what the schema provides?

Schema coverage 0%; description adds meaning for offset_spec and timeout but ignores topic_name, partition, and limit, which have defaults and types not explained.

Input schemas describe structure but not intent. Descriptions should explain non-obvious parameter relationships and valid value ranges.

Purpose5/5

Does the description clearly state what the tool does and how it differs from similar tools?

States clearly 'Consumes messages from a topic', providing specific verb and resource. Distinct from siblings like produce_message or get_consumer_group_offsets.

Agents choose between tools based on descriptions. A clear purpose with a specific verb and resource helps agents select the right tool.

Usage Guidelines2/5

Does the description explain when to use this tool, when not to, or what alternatives exist?

No guidance on when to use this tool versus alternatives (e.g., produce_message, describe_topic). Missing context like offsets management.

Agents often have multiple tools that could apply. Explicit usage guidance like "use X instead of Y when Z" prevents misuse.

Install Server

Other Tools

Latest Blog Posts

MCP directory API

We provide all the information about MCP servers via our MCP API.

curl -X GET 'https://glama.ai/api/mcp/v1/servers/wklee610/kafka-mcp'

If you have feedback or need assistance with the MCP directory API, please join our Discord server