Skip to content
Open app Talk to sales
Apache Kafka logo

Apache Kafka integration

Publish and consume messages on an Apache Kafka cluster.

Start building Use Apache Kafka with your AI
Actions
2
Triggers
2
Auth
Custom auth
License
MIT, open source
Updated
October 2026

About the Apache Kafka integration

Add the Apache Kafka piece to a flow, connect your account once, and the rest of the builder can read from it and write to it. Because the piece is open source you can run it on our cloud or self-host it, and combine Apache Kafka with 770+ other apps in the same flow.

Triggers

Start a flow the moment something happens in Apache Kafka

Each trigger below can start a flow on its own, either instantly or on a schedule.

  • 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

Actions

Everything Activepieces can do in Apache Kafka

Drop any of these into a flow and fill in the fields. No code is required.

  • 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

Use Apache Kafka in a flow

Connect Apache Kafka once and every trigger and action above is yours to drop into the builder, alongside 770+ other apps. Free to start, on our cloud or your own servers.

Build a Apache Kafka flowTalk to sales

Apache Kafka, answered.

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

Add the Apache Kafka piece to a flow, then authenticate with Custom auth. Once connected, its 2 triggers and 2 actions are available anywhere in the builder.

"New message in topic" can start a flow that runs "Publish message", and you can chain Apache Kafka together with any of 770+ other apps and AI steps in between.

Yes. Activepieces is fully self-hostable, so you can run the Apache Kafka piece on your own infrastructure with your connections and your data staying in your environment.

Yes. Every piece you connect can be exposed over one Activepieces MCP server, so Claude, Cursor, Windsurf or any MCP client can call Apache Kafka actions as tools.

More developer tools integrations

Browse all integrations
Supabase

Supabase

The open-source Firebase alternative

Developer Tools22 actions · 1 trigger
GitHub

GitHub

Developer platform that allows developers to create, store, manage and share their code

Developer Tools19 actions · 14 triggers
AWS Lambda

AWS Lambda

Invoke functions and watch for new ones

Developer Tools3 actions · 1 trigger
Base44

Base44

Build and manage custom apps with databases and entities

Developer Tools3 actions · 1 trigger
Backblaze

Backblaze

Scalable storage in the cloud

Developer Tools2 actions · 1 trigger
Datadog

Datadog

Cloud monitoring and analytics platform

Developer Tools3 actions