Python

Use the Kafkorama Python SDK to connect, subscribe, and publish to real-time Streaming API endpoints.

The Kafkorama Python SDK gives developers a simple and powerful interface to build real-time applications, services, or data pipelines using Python.

In Kafkorama, subjects serve directly as Streaming API endpoints. This SDK enables your Python code to interact with those endpoints for both publishing and consuming real-time data.

With this SDK, you can:

  • Connect to a cluster of one or more Kafkorama Gateway nodes
  • Subscribe to one or more Streaming API endpoints (subjects) and receive real-time updates
  • Publish real-time messages to subjects
  • Handle reconnections and error events
  • Build reactive backend services, analytics modules, or automation scripts

This SDK is ideal for server-side use cases such as data ingestion, real-time processing, and integration with Python-based platforms.

To get started, follow the Run with Docker guide to launch a local Kafkorama instance. Below, you’ll find installation instructions, usage examples, and SDK references:

© 2025 MigratoryData. All rights reserved.