Skip to content
Apache Kafka logo

Apache Kafka MCP server

Publish and consume messages on an Apache Kafka cluster.

Apache Kafka is not a separate install. One Activepieces MCP server exposes it alongside 770+ other apps, behind a single URL.

Tools
2
Works with
Any MCP client
Auth
Custom auth
License
MIT, open source
Updated
October 2026

About the Apache Kafka MCP server

Connect Apache Kafka once in Activepieces and every action it ships becomes a tool your assistant can call, behind the same server URL as the rest of your apps. Your agent reaches Apache Kafka and 770+ other apps over a single connection, on our cloud or a self-hosted install.

Tools

Apache Kafka tools your AI can run

Once connected, your assistant can call any of these Apache Kafka actions by asking in plain language.

  • Publish message

    Publishes one message to a Kafka topic and returns its partition and offset.

    5 fields

  • Publish messages

    Publishes several messages to a Kafka topic in one step and returns a partition and offset for each.

    2 fields

Triggers

Apache Kafka events your agent can watch

These start a run the moment something happens in Apache Kafka, so work gets picked up on its own.

  • New message in topic

    Reads each new message on a topic, including its payload, key, partition, and offset. Messages are marked as read before the flow runs, so if a run fails, that message is not delivered again.

    5 fields

  • New messages in topic

    Reads a batch of new messages on a topic in one run. Messages are marked as read before the flow runs, so if a run fails, those messages are not delivered again.

    5 fields

Give your assistant Apache Kafka

Connect Apache Kafka once and every tool above is callable from Claude, Cursor or any MCP client, behind the same server URL as 770+ other apps. Free to start.

Apache Kafka MCP, answered.

No. That is the point of it. One Activepieces server exposes Apache Kafka alongside every other piece you connect, so your client keeps a single connection.

Yes. Activepieces is open source and free to start, and the MCP server is included on every plan, from the free cloud tier to any self-hosted deployment.

Connect Apache Kafka in Activepieces, enable the server under Settings → MCP Server, then paste your server URL into your client config. It authenticates over OAuth on first use.

It can call 2 tools, including Publish message, Publish messages, and chain them with steps in other apps inside the same run.

Connections use OAuth2 with limited scopes and are stored under 256-bit encryption, with no API to read them back, so an agent gets scoped access rather than your keys.