Apache Kafka REST API

API Endpoints

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())

Related APIs