pipekafka 0.2.3

A pipebase plugin using rdkafka
Documentation 
1
2
3
4
5
6

pub(crate) const GROUP_ID: &str = "group.id";
pub(crate) const BOOTSTRAP_SERVERS: &str = "bootstrap.servers";
pub(crate) const ENABLE_PARTITION_EOF: &str = "enable.partition.eof";
pub(crate) const SESSION_TIMEOUT_MS: &str = "session.timeout.ms";
pub(crate) const ENABLE_AUTO_COMMIT: &str = "enable.auto.commit";
pub(crate) const MESSAGE_TIMEOUT_MS: &str = "message.timeout.ms";