psql-streamer
Event streamer
A service that streams database events from PostgreSQL to Kafka using logical replication protocol.
Stream database events from PostgreSQL to Kafka
58 stars
5 watching
13 forks
Language: Go
last commit: over 4 years ago
Linked from 2 awesome lists
eventsjsonkafkalogicalpostgresqlreplicationstream
avelino/awesome-go
xwjdsh/awesome-go-extraRelated projects:
| Repository | Description | Stars |
|---|---|---|
 hasura/pgdeltastream | A service to stream Postgres changes over websockets using logical replication | 253 |
 confluentinc/ksql | A database for real-time stream processing applications built on top of Apache Kafka. | 125 |
 nodefluent/kafka-streams | A Node.js library implementing Kafka Streams functionality for stream state processing and table representation. | 831 |
 lgouellec/streamiz | A .NET library for processing and aggregating stream data from Apache Kafka | 469 |
 streamthoughts/kafka-connect-file-pulse | A tool that enables streaming and processing of various file formats into Apache Kafka | 324 |
 ibmstreams/streamsx.kafka | A toolkit for integrating Apache Kafka with Stream Processor SPL applications | 13 |
 turbolytics/sql-flow | An open-source tool that enables writing Kafka stream processing logic using standard SQL syntax. | 69 |
 yannael/kafka-sparkstreaming-cassandra | An environment for experimenting with real-time data processing using Kafka, Spark streaming, and Cassandra | 97 |
 wintoncode/winton-kafka-streams | A Python implementation of Apache Kafka's Streams API for stream processing applications | 313 |
 lampctl/go-sse | A Go package for sending and receiving event streams from servers to clients | 12 |
 timeplus-io/proton | A fast and lightweight streaming SQL engine that enables developers to process and analyze real-time data from various sources. | 1,570 |
 raystack/firehose | Delivers real-time streaming data to various destinations | 325 |
| streamthoughts/azkarra-streams | A lightweight Java framework to develop and manage cloud-native streaming microservices based on Apache Kafka Streams. | 186 |
 streamreasoning/csparql-engine | A Java-based library designed to simplify reasoning over RDF streams using Csparql-engine | 34 |
 gazette/core | Enables teams to build platforms mixing SQL, batch, and real-time streaming processing paradigms | 718 |