winton-kafka-streams

Stream processor

A Python implementation of Apache Kafka's Streams API for building stream processing applications

A Python implementation of Apache Kafka Streams

GitHub

311 stars
32 watching
55 forks
Language: Python
last commit: over 7 years ago
Linked from 2 awesome lists

kafka-streamslibrdkafkapythonstreaming-api

Backlinks from these awesome lists:

Related projects:

RepositoryDescriptionStars
nodefluent/kafka-streamsA Node.js library implementing Kafka Streams functionality for stream state processing and table representation.831
quixio/quix-streamsA Python framework for real-time data processing on Apache Kafka streams1,246
streamthoughts/kafka-connect-file-pulseA tool that enables streaming and processing of various file formats into Apache Kafka324
ibmstreams/streamsx.kafkaA toolkit for integrating Apache Kafka with Stream Processor SPL applications13
confluentinc/ksqlA database for real-time stream processing applications built on top of Apache Kafka.133
gojek/zigguratA framework for building stateless applications on top of Kafka stream processing399
turbolytics/sql-flowAn open-source tool that enables writing Kafka stream processing logic using standard SQL syntax.73
maki-nage/makinageStream Processing Library and Framework38
lgouellec/streamizA .NET library for processing and aggregating stream data from Apache Kafka477
nmaquet/kasperA lightweight library for processing Kafka topics with idempotent at-least-once semantics439
turtlesoupy/haskakafkaProvides a Haskell interface to Kafka, enabling producers and consumers to interact with the platform.72
keilerkonzept/topkAn implementation of probabilistic data structures for approximate data stream processing4
yannael/kafka-sparkstreaming-cassandraAn environment for experimenting with real-time data processing using Kafka, Spark streaming, and Cassandra97
sderosiaux/kafka-streams-consumer-offsets-to-jsonConverts Kafka __consumer_offsets to JSON13
jitendra3109/apachekafkaA curated resource list and community hub for building real-time data pipelines with Apache Kafka35