Extensions / Replication and streams
Produce messages to Apache Kafka from PostgreSQL
pgext.cloud · Source code · Documentation · License text · Control file
| Package | pg_kafka |
|---|---|
| Version | 0.0.1 |
| PostgreSQL versions | 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 |
| Repository | Unspecified |
| Extension type | Preloaded |
| Project status | Archived |
| Requires CREATE EXTENSION | Yes |
| Requires preload | Yes |
| Trusted | No |
| Relocatable | No |
| Shared libraries | pg_kafka |
| Schema | kafka |
| Stars | 112 |
| Latest commit | 2015-04-03 |
| Catalogue updated | 2026-08-30 |
| kafka_fdw | kafka Foreign Data Wrapper for CSV formatted messages |
| pg_kafka_events | Publishes PostgreSQL logical-decoding change events to Apache Kafka through a background worker. |
| pgq | Generic queue for PostgreSQL |
| pipeline_kafka | Integrate PipelineDB with Kafka for background-worker consumption, production, offsets, and lag monitoring |
| amqp | Publish messages to AMQP brokers from PostgreSQL |
| pg_redispub | Publish channel messages from PostgreSQL to a local Redis server |
| pg_turret | Capture PostgreSQL logs and export structured events to HTTP, Kafka, or Sentry |
| putpostlogic | Unreleased logical decoding output-plugin prototype that emits JSON changes through PostgreSQL, Kafka, or Nanomsg. |
| pg_kafka | Kafka foreign data wrapper for PostgreSQL. |