Kafka in Docker.
ShellApache License 2.0slowing
19 projectsData Ingestion
Kafka in Docker.
ShellApache License 2.0slowing
CLI tool to copy data between databases with a single command. Supports 50+ sources including PostgreSQL, MySQL, MongoDB, Salesforce, Shopify to any data warehouse.
GoOtheractive
Data Acquisition and Processing Made Easy. Deprecated.
GoOtherslowingarchived
Node.js client for Apache Kafka 0.8.
JavaScriptMIT Licenseslowing
Pinterest's Kafka to S3 distributed consumer.
JavaApache License 2.0steady
Simplified command-line administration for Kafka brokers.
RubyApache License 2.0dormant
A Kafka Proxy, solving problems like encrypting your Kafka data at rest.
JavaApache License 2.0active
A PostgreSQL extension to produce messages to Apache Kafka.
CMIT Licensedormantarchived
Python PDF-to-Markdown orchestrator. Classifies each page and routes to the optimal backend (PyMuPDF, Docling, RapidOCR, Gemini Flash), emitting Markdown plus a per-page confidence score so ingestion pipelines can quarantine low-trust pages before feeding LLMs or retrieval.
PythonMIT Licenseactive
Kafka-winston logger for Node.js from Uber.
JavaScriptMIT Licensedormantarchived
OSS Reverse ETL CLI. Sync data from warehouses to business tools via YAML.
PythonApache License 2.0active
Live import all your Google Sheets to your data warehouse.
PHPMIT Licensesteady
High-performance, streaming-first ETL engine for Node.js and TypeScript with constant memory footprint.
TypeScriptMIT Licensesteady
Conflict-free merge for DataFrames, JSON, ML models & distributed agents — powered by CRDTs.
PythonOtheractive
Open-source self-hosted analytics pipeline that lands raw events as Parquet in your own object storage. Uses NATS JetStream for durable buffering and BigQuery external tables for querying. Designed for teams that want to own their raw event data.
PythonApache License 2.0active
Data ingestion engine that connects 400+ Singer taps to Parquet files in cloud buckets (S3, GCS, Azure). Streaming, incremental, with auto-catalog.
PythonApache License 2.0steady
Lightweight Node.js ETL framework for databases → data lakes/warehouses.
TypeScriptMIT Licensesteady
Context-Aware RAG Processing Queue for high availability and adaptive rate-limiting.
PythonMIT Licenseactive
CLI tool to enrich CSV files with company data (financials, contacts, metadata) from 250M+ company records. Available on npm.
JavaScriptMIT Licenseactivearchived
Back to Awesome DataEngineeringSearch Awesome DataEngineering →