Extensions / Replication and streams
Integrate PipelineDB with Kafka for background-worker consumption, production, offsets, and lag monitoring
pgext.cloud · Source code · Documentation · License text · Control file
| Package | pipeline_kafka |
|---|---|
| Version | 1.0.0 |
| Repository | Unspecified |
| Extension type | Preloaded |
| Requires CREATE EXTENSION | Yes |
| Requires preload | Yes |
| Trusted | No |
| Relocatable | No |
| Shared libraries | pipelinedb, pipeline_kafka |
| Schema | pipeline_kafka |
| Stars | 62 |
| Latest commit | 2018-12-17 |
| Latest release | 2016-12-25 |
| Catalogue updated | 2026-08-30 |
| pipelinedb | Run continuous SQL queries for high-throughput incremental time-series aggregation in PostgreSQL |
| kafka_fdw | kafka Foreign Data Wrapper for CSV formatted messages |
| pg_turret | Capture PostgreSQL logs and export structured events to HTTP, Kafka, or Sentry |
| pg_kafka_events | Publishes PostgreSQL logical-decoding change events to Apache Kafka through a background worker. |
| pg_kafka | Kafka foreign data wrapper for PostgreSQL. |
| pipeline_kinesis | Consume Amazon Kinesis streams into PipelineDB streams with dynamic background workers and persisted shard positions |
| putpostlogic | Unreleased logical decoding output-plugin prototype that emits JSON changes through PostgreSQL, Kafka, or Nanomsg. |
| bwcontrol | Bottledwater control extension |
| kadb_fdw | Transactional Kafka foreign data wrapper for Arenadata DB and Greenplum |
| pipelinedb | Run continuous SQL queries for high-throughput incremental time-series aggregation in PostgreSQL |
| streaming_lag | A custom background worker process to measure lag in units of time |