Crate streambed_kafka

kafka

Provides commit log functionality to connect with the Kafka HTTP API, with one difference… Kafka’s HTTP API does not appear to provide a means of streaming consumer records. We have therefore introduced a new API call to subscribe to topics and consume their events by assuming that the server will keep the connection open.

Modules

args

Provides command line arguments that are typically used for all services using this module.

Structs

KafkaRestCommitLog

A commit log holds topics and can be appended to and tailed.