kasper
Kafka processor
A lightweight library for processing Kafka topics with idempotent at-least-once semantics
Kasper is a lightweight library for processing Kafka topics.
439 stars
23 watching
24 forks
Language: Go
last commit: about 7 years ago
Linked from 2 awesome lists
golang-librarykafkastream-processing
semantalytics/awesome-kafka
dharmeshkakadia/awesome-kafkaRelated projects:
| Repository | Description | Stars |
|---|---|---|
 fgeller/kt | A command-line tool for interacting with Apache Kafka clusters | 948 |
 lgouellec/streamiz | A .NET library for processing and aggregating stream data from Apache Kafka | 469 |
 xitonix/trubka | A command-line tool for interacting with Kafka clusters | 333 |
 datadog/kafka-kit | Tools and services for efficient management of Kafka topics and brokers | 489 |
 line/decaton | A framework for high-throughput, concurrent task processing on Apache Kafka | 335 |
 wintoncode/winton-kafka-streams | A Python implementation of Apache Kafka's Streams API for stream processing applications | 313 |
 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 |
 karafka/karafka | A Ruby-based framework for efficient processing and management of Apache Kafka data streams in Rails applications | 2,091 |
 gojek/ziggurat | A framework for building stateless applications on top of Kafka stream processing | 398 |
 jitendra3109/apachekafka | A curated resource list and community hub for building real-time data pipelines with Apache Kafka | 34 |
 cswank/kcli | A command-line interface to browse Kafka topics and partitions | 216 |
 jdamick/kafka | A Go implementation of a distributed publish-subscribe messaging system | 130 |
 dylanmei/logspout-kafka | A logspout adapter for writing Docker container logs to Kafka topics | 52 |
 morganstanley/modern-cpp-kafka | A C++ wrapper around librdkafka to simplify and improve Kafka client API usage | 359 |