Data Ingestion
Open-Source Change Data Capture Platform
★ 4.7
Polyglot Document Intelligence
★ 3.8
N/A — Java-based Kafka connectorpip install kreuzbergN/A — Java-based Kafka connectorpip install kreuzbergPython 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.
Python data engineers use Kreuzberg to build document ingestion pipelines that extract text from uploaded PDFs, scanned images, and Office files. The async API integrates cleanly into FastAPI-based document processing services — an endpoint accepts a file upload, Kreuzberg extracts the text asynchronously, and the pipeline stores the result in a search index or warehouse for downstream analysis.
Individual Tool Pages