chobostar / pg_listenerLinks
Go application to capture inserts into PostgreSQL table and produce events to Apache Kafka using replication slot and WAL
☆37Updated 2 years ago
Alternatives and similar repositories for pg_listener
Users that are interested in pg_listener are comparing it to the libraries listed below
Sorting:
- A Golang client for ksqlDB☆70Updated 3 years ago
- Stream database events from PostgreSQL to Kafka☆61Updated 5 years ago
- An all-inclusive protoc Docker image for the Jaeger project☆94Updated last year
- Golang SDK for Apache Flink Stateful Functions☆31Updated 4 years ago
- Consistent replication from postgres to golang via protocol buffers.☆18Updated 7 years ago
- GUI for Nats Streaming server (https://developer.aliyun.com/mirror/npm/package/nats-streaming-ui)☆58Updated last year
- Altinity Dashboard helps you manage ClickHouse installations controlled by clickhouse-operator.☆68Updated this week
- Pulsar Beam is a streaming service via HTTP built on Apache Pulsar.☆60Updated 3 years ago
- ksqldb-go client☆43Updated 2 years ago
- A library provides consumer/producer to work with kafka, avro and schema registry☆55Updated 4 years ago
- Apache Kafka Streams for Golang☆50Updated 2 years ago
- Minimalist rules engine for Golang☆32Updated last year
- Temporal Dashboards☆109Updated 3 weeks ago
- NATS to Kafka Bridging☆150Updated 6 months ago
- go library for kubemq server☆49Updated 9 months ago
- Golang Server for https://github.com/temporalio/ui☆95Updated last week
- ☆66Updated 3 months ago
- a simple Golang library that allows you to stream postgresql changes over a configurable streaming interface☆17Updated 4 years ago
- Nats Java Flink Connector☆26Updated this week
- A curated list of awesome things related to the Cadence and Temporal Workflow Engines☆83Updated 4 years ago
- SQL (Postgres/MySQL) Pub/Sub for the Watermill project.☆79Updated last month
- Kubemqctl is a command line interface (CLI) for KubeMQ , Kubernetes Message Broker☆23Updated 2 years ago
- A Kubernetes Operator to orchestrate Benthos pipelines☆44Updated last year
- ☆52Updated 2 weeks ago
- Flatten/unflatten nested map or JSON object in Golang☆69Updated 2 years ago
- Go client for Trino☆174Updated 2 weeks ago
- Collection of runnable, reference examples using NATS (https://nats.io)☆195Updated 5 months ago
- Bloomfilter written in Golang, includes rotation and RPC☆87Updated last month
- kafkaproxy is a reverse proxy for the wire protocol of Apache Kafka.☆86Updated 2 years ago
- AsyncAPI Event Gateway☆57Updated last year