Loading...
Data Ingestion
Distributed Pub-Sub Messaging
★ 4.5
Open-Source Change Data Capture Platform
★ 4.7
pip install pulsar-clientN/A — Java-based Kafka connectorpip install pulsar-clientN/A — Java-based Kafka connectorPython data engineers use the `pulsar-client` Python SDK to produce and consume messages from Pulsar topics. Pulsar Functions can be written in Python to perform lightweight transformations — filtering, enriching, or routing messages — without deploying a separate Faust or Spark Streaming cluster. Pulsar's topic compaction and retention policies simplify stateful event stream management.
Python data engineers typically run Debezium as the CDC producer and write Python consumers of the change streams it generates. After deploying Debezium connectors via Docker Compose or Kubernetes, Python services consume CDC events from Kafka topics using confluent-kafka or kafka-python — receiving full before/after row images for every database change, which are then written as Parquet to S3 or applied as upserts to a data warehouse. For teams without Kafka, Debezium Server sinks directly to AWS Kinesis or Redis Streams, both of which have first-class Python client libraries (boto3, redis-py), keeping the Python integration straightforward.
Individual Tool Pages