Channel-based event I/O processors.
This crate allows to collect events from text files, pcap files, and Apache Kafka servers, distribute them to multiple threads, and optionally collect them to send to Kafka.
A partial implementation of Fluentd Forward Protocol.
Reading/writing events from/to Apache Kafka servers.
Reading packets as events from a pcap input.
Reading lines as events from a text input.
The error type for event I/O operations.
A trait for a single event from any type of data source.
A trait for a data source that produces messages of type
Spawns worker threads to process events in parallel.