RTBHOUSE / kafka-workersLinks
Kafka Workers is a client library which unifies records consuming from Kafka and processing them by user-defined WorkerTasks.
☆31Updated 3 years ago
Alternatives and similar repositories for kafka-workers
Users that are interested in kafka-workers are comparing it to the libraries listed below
Sorting:
- A distributed generic query layer for Apache Kafka Interactive Queries☆26Updated 7 years ago
- Maelstrom is an open source Kafka integration with Spark that is designed to be developer friendly, high performance (millisecond stream …☆22Updated 8 years ago
- A Datastax java driver policy to auto handle DC failures☆17Updated 9 years ago
- Single-threaded off-heap object store☆48Updated 2 years ago
- RPC Benchmark of gRPC, Aeron and KryoNet☆73Updated 2 years ago
- Code examples for my blog posts☆22Updated 6 years ago
- ☆57Updated 3 years ago
- ☆22Updated 8 years ago
- Set of real time stream processing algorithms that can be used by big data streaming platform☆72Updated 3 months ago
- High performance native memory access for Java.☆126Updated 5 months ago
- Common utilities for Apache Kafka☆36Updated 2 years ago
- Flink Examples☆38Updated 9 years ago
- Graph Analytics with Apache Kafka☆106Updated this week
- Yuvi is an in-memory storage engine for recent time series metrics data.☆48Updated 7 years ago
- Multiple readers and writers concurrency tests.☆128Updated 8 years ago
- A simple benchmark of some off heap solutions (BigMemory Go, MapDB, Java Chronicle...)☆23Updated 12 years ago
- Bloom filters for Java☆66Updated last year
- High-performance Raft-based Java Web Container☆63Updated 6 years ago
- Production-ready Java implementation of the Xor Filter.☆18Updated 5 years ago
- A library for strong, schema based conversion between 'natural' JSON documents and Avro☆18Updated last year
- A set of tools to ease working with Zookeeper and Kafka.☆23Updated 9 years ago
- Spooker is a dynamic framework for processing high volume data streams via processing pipelines☆30Updated 9 years ago
- simple rules engine☆92Updated 5 years ago
- Spark Connector for Hazelcast☆22Updated 4 years ago
- Union, intersection, and set cardinality in loglog space☆57Updated 2 years ago
- DDSketch: A Fast and Fully-Mergeable Quantile Sketch with Relative-Error Guarantees.☆123Updated last month
- BlobIt - a Distributed Large Object Storage☆39Updated last month
- ☆29Updated 3 years ago
- ☆26Updated 5 years ago
- A fast key-value store written in Java that outperforms levelDB, kyoto cabinet and rocksDB☆55Updated 2 years ago