flier / tokio-kafkaLinks
Asynchronous Rust client for Apache Kafka
☆31Updated 7 years ago
Alternatives and similar repositories for tokio-kafka
Users that are interested in tokio-kafka are comparing it to the libraries listed below
Sorting:
- Lock free bounded non blocking pub sub queue☆76Updated 4 years ago
- A concurrent hash table for Rust☆61Updated 5 years ago
- Concurrent hash trie☆55Updated 4 years ago
- Abstract name service traits for rust☆20Updated 7 years ago
- Support for Linux kernel aio within Tokio.☆52Updated 3 years ago
- Atomically updatable Arc implementation using crossbeam-epoch for memory reclamation.☆42Updated 6 years ago
- A connection pool implementation for tokio☆23Updated 7 years ago
- native timers for futures 0.3☆25Updated 6 years ago
- Access File System operations off-thread, using a Futures.☆69Updated 6 years ago
- Utilities for encoding and decoding frames with async/await☆75Updated 4 years ago
- A thread pool for rust/tokio that can process file requests and send data to the socket with zero copy (using sendfile)☆29Updated 8 years ago
- An I/O-oriented tokio runtime thread pool☆49Updated 5 years ago
- Time Interval Counting for Rust - stats based on start/stop times for events☆75Updated 6 years ago
- Async tracing capabilities for the log crate☆99Updated 4 years ago
- Asynchronous byte buffers and pipes for concurrent I/O programming.☆101Updated this week
- ☆20Updated 4 years ago
- Dynamically query a type-erased object for any trait implementation☆65Updated 2 years ago
- Streamline updating a Tokio 0.1 application to Tokio 0.2.☆51Updated 4 years ago
- A library that allows to listen network sockets with proper resource limits and error handling☆30Updated 6 years ago
- ☆47Updated 4 years ago
- ☆70Updated 3 years ago
- Epoch-based garbage collection☆81Updated 6 years ago
- Set theory applied on sorted and deduplicated slices.☆46Updated 2 years ago
- An experimental asynchronous runtime based on `io-uring`.☆77Updated 4 years ago
- A pool of reusable values☆50Updated 5 years ago
- Work-stealing thread pool for executiong futures☆42Updated 7 years ago
- An implementation of the `group_by` Haskell function for slice and strings☆54Updated 2 years ago
- a place to coordinate our shared efforts☆16Updated 6 years ago
- Concurrent work-stealing deque☆47Updated 6 years ago
- LRU cache settable via size or time to live☆105Updated 3 years ago