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:
- Production-ready Java implementation of the Xor Filter.☆18Updated 5 years ago
- 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
- Blazing Fast Distributed Cache☆38Updated last month
- Set of real time stream processing algorithms that can be used by big data streaming platform☆72Updated 2 months ago
- BlobIt - a Distributed Large Object Storage☆37Updated last month
- Single-threaded off-heap object store☆48Updated 2 years ago
- Multiple readers and writers concurrency tests.☆128Updated 8 years ago
- Serializer/Deserializer for Kafka to serialize/deserialize Protocol Buffers messages☆65Updated 2 weeks ago
- A fast key-value store written in Java that outperforms levelDB, kyoto cabinet and rocksDB☆55Updated 2 years ago
- ☆57Updated 3 years ago
- Union, intersection, and set cardinality in loglog space☆58Updated 2 years ago
- Flink Examples☆39Updated 9 years ago
- Kafka Interceptor for Zipkin☆35Updated 3 years ago
- A client-side RPC library for conjure-java☆33Updated this week
- A set of tools to ease working with Zookeeper and Kafka.☆23Updated 9 years ago
- Mirror of Apache DirectMemory☆53Updated last year
- High performance native memory access for Java.☆126Updated 4 months ago
- Graph Analytics with Apache Kafka☆106Updated 2 weeks ago
- Dropwizard bundle and reporter for Prometheus☆26Updated last week
- Spark Connector for Hazelcast☆22Updated 4 years ago
- Yuvi is an in-memory storage engine for recent time series metrics data.☆48Updated 7 years ago
- Concurrent Bloom Filter☆15Updated 8 years ago
- ☆29Updated 3 years ago
- A hashmap implementation for Java that stores map entries off-heap☆72Updated 5 years ago
- A Datastax java driver policy to auto handle DC failures☆17Updated 9 years ago
- DDSketch: A Fast and Fully-Mergeable Quantile Sketch with Relative-Error Guarantees.☆124Updated 2 weeks ago
- simple rules engine☆92Updated 5 years ago
- Classes for multithreading that expand on java.util.concurrent, adding convenience, efficiency and new tools to multithreaded Java progra…☆48Updated 5 years ago
- An application that records stats about consumer group offset commits and reports them as prometheus metrics☆14Updated 6 years ago