Message Queue & Streaming Basic Auth

Apache Kafka REST API

Distributed event streaming platform for real-time data

Apache Kafka is a distributed streaming platform used for building real-time data pipelines and streaming applications. It enables high-throughput, fault-tolerant publish-subscribe messaging with persistent storage, allowing organizations to process and analyze event streams at scale. Developers use Kafka for event sourcing, log aggregation, real-time analytics, and microservices communication.

Base URL https://kafka-rest-proxy.example.com/v3

API Endpoints

Method	Endpoint	Description
GET	`/clusters`	List all Kafka clusters available in the environment
GET	`/clusters/{cluster_id}/topics`	Get all topics in a specific Kafka cluster
POST	`/clusters/{cluster_id}/topics`	Create a new topic with specified partitions and replication factor
GET	`/clusters/{cluster_id}/topics/{topic_name}`	Get detailed configuration and metadata for a specific topic
DELETE	`/clusters/{cluster_id}/topics/{topic_name}`	Delete a topic and all its data from the cluster
POST	`/clusters/{cluster_id}/topics/{topic_name}/records`	Produce a message record to a specific topic partition
GET	`/clusters/{cluster_id}/topics/{topic_name}/partitions`	List all partitions for a specific topic
GET	`/clusters/{cluster_id}/consumer-groups`	List all consumer groups registered in the cluster
GET	`/clusters/{cluster_id}/consumer-groups/{group_id}`	Get detailed information about a specific consumer group
GET	`/clusters/{cluster_id}/consumer-groups/{group_id}/consumers`	List all active consumers in a consumer group
GET	`/clusters/{cluster_id}/brokers`	List all broker nodes in the Kafka cluster
GET	`/clusters/{cluster_id}/brokers/{broker_id}`	Get detailed configuration and status for a specific broker
POST	`/consumers/{group_id}`	Create a new consumer instance in a consumer group
GET	`/consumers/{group_id}/instances/{instance_id}/records`	Consume records from subscribed topics for a consumer instance
POST	`/consumers/{group_id}/instances/{instance_id}/subscription`	Subscribe a consumer instance to one or more topics

Code Examples

# Produce a message to a topic
curl -X POST https://kafka-rest-proxy.example.com/v3/clusters/cluster-1/topics/orders/records \
  -H 'Content-Type: application/json' \
  -u username:password \
  -d '{
    "partition_id": 0,
    "value": {
      "type": "JSON",
      "data": {
        "order_id": "12345",
        "customer": "john@example.com",
        "total": 99.99
      }
    },
    "key": {
      "type": "STRING",
      "data": "order-12345"
    }
  }'

// Produce a message to Kafka topic
const response = await fetch('https://kafka-rest-proxy.example.com/v3/clusters/cluster-1/topics/orders/records', {
  method: 'POST',
  headers: {
    'Content-Type': 'application/json',
    'Authorization': 'Basic ' + btoa('username:password')
  },
  body: JSON.stringify({
    partition_id: 0,
    value: {
      type: 'JSON',
      data: {
        order_id: '12345',
        customer: 'john@example.com',
        total: 99.99
      }
    },
    key: {
      type: 'STRING',
      data: 'order-12345'
    }
  })
});

const result = await response.json();
console.log('Message produced:', result);

import requests
from requests.auth import HTTPBasicAuth
import json

# Produce a message to Kafka topic
url = 'https://kafka-rest-proxy.example.com/v3/clusters/cluster-1/topics/orders/records'
headers = {'Content-Type': 'application/json'}
auth = HTTPBasicAuth('username', 'password')

payload = {
    'partition_id': 0,
    'value': {
        'type': 'JSON',
        'data': {
            'order_id': '12345',
            'customer': 'john@example.com',
            'total': 99.99
        }
    },
    'key': {
        'type': 'STRING',
        'data': 'order-12345'
    }
}

response = requests.post(url, headers=headers, auth=auth, json=payload)
print('Message produced:', response.json())

Use Apache Kafka from Claude / Cursor / ChatGPT

Get a hosted MCP endpoint for Apache Kafka. Paste your Apache Kafka API key, copy back one URL, drop it into Claude Desktop, Cursor, or any AI client that supports remote MCP. Your AI calls Apache Kafka directly with your credentials — no local install, works on mobile.

kafka_produce_message Produce messages to Kafka topics with automatic serialization and partitioning support

kafka_consume_messages Consume and process messages from Kafka topics with configurable consumer groups and offset management

kafka_list_topics Discover and list all available Kafka topics across clusters with metadata including partition counts and replication factors

kafka_create_topic Create new Kafka topics with custom partition counts, replication factors, and configuration settings

kafka_monitor_consumer_lag Monitor consumer group lag and offset positions to identify processing bottlenecks and ensure data freshness

Connect in 60 seconds

Paste your Apache Kafka key → get an MCP URL → paste into Claude/Cursor. Hosted by IOX, encrypted at rest.

Connect Apache Kafka to your AI →

Apache Kafka REST API

API Endpoints

Sponsor this page

Code Examples

Use Apache Kafka from Claude / Cursor / ChatGPT

Connect in 60 seconds

Related APIs