Lib.rs

Cargo Features

StreamConsumerTask has no features set by default.

[dependencies]
stream-consumer-task = { version = "0.1.0", features = ["kafka"] }

kafka

Enables rdkafka

Affects stream-consumer-task::KafkaStreamConsumerAdapter…