sql-flow
Kafka consumer
An open-source tool that enables writing Kafka stream processing logic using standard SQL syntax.
DuckDB for streaming data
73 stars
5 watching
7 forks
Language: Python
last commit: 9 months ago
Linked from 1 awesome list
davidgasquez/awesome-duckdbRelated 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 building stream processing applications | 311 |
 quixio/quix-streams | A Python framework for real-time data processing on Apache Kafka streams | 1,246 |
 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 | 85 |
 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. | 133 |
 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 | 477 |