sql-flow
Kafka consumer
An open-source tool that enables writing Kafka stream processing logic using standard SQL syntax.
DuckDB for streaming data
69 stars
3 watching
6 forks
Language: Python
last commit: 7 months ago
Linked from 1 awesome list
Related projects:
Repository | Description | Stars |
---|---|---|
streamthoughts/kafka-connect-file-pulse | A tool that enables streaming and processing of various file formats into Apache Kafka | 324 |
wintoncode/winton-kafka-streams | A Python implementation of Apache Kafka's Streams API for stream processing applications | 313 |
quixio/quix-streams | A Python framework for real-time data processing on Apache Kafka streams | 1,190 |
nodefluent/kafka-streams | A Node.js library implementing Kafka Streams functionality for stream state processing and table representation. | 831 |
rayokota/kwack | In-memory analytics tool for Kafka data using DuckDB | 79 |
mre/kafka-influxdb | A Kafka consumer for InfluxDB that buffers metric data during high loads and enables reliable sending of metrics from remote locations. | 216 |
ibmstreams/streamsx.kafka | A toolkit for integrating Apache Kafka with Stream Processor SPL applications | 13 |
confluentinc/ksql | A database for real-time stream processing applications built on top of Apache Kafka. | 125 |
turtlesoupy/haskakafka | Provides a Haskell interface to Kafka, enabling producers and consumers to interact with the platform. | 72 |
xitonix/trubka | A command-line tool for interacting with Kafka clusters | 333 |
linkedin/kafka-tools | A collection of tools and utilities for managing Apache Kafka | 595 |
nmaquet/kasper | A lightweight library for processing Kafka topics with idempotent at-least-once semantics | 439 |
yannael/kafka-sparkstreaming-cassandra | An environment for experimenting with real-time data processing using Kafka, Spark streaming, and Cassandra | 97 |
ysn2233/kafka-prompt | An interactive command-line client with auto-completion for Kafka commands and their optional arguments. | 6 |
lgouellec/streamiz | A .NET library for processing and aggregating stream data from Apache Kafka | 469 |