Crate janus_kafka[−][src]

Janus-Kafka

Kafka adapter for Janus.

Structs

KafkaPublisher	Publishes messages to Kafka
KafkaPublisherStatus	Allows a healthcheck to be performed on the Kafka publisher.
KafkaSubscriber	Consumes messages from Kafka
KafkaSubscriberStatus	Allows a healthcheck to be performed on the Kafka subscriber.
OffsetError	OffsetError is raised when an `Offset` can't be created from a `String`.
PublisherAcker	Acknowledges messages from the Publisher.
PublisherConfig	Configuration options for a Publisher
PublisherMessage	A `Message` to be published to Kafka.
SubscriberAcker	Acknowledges messages from the Subscriber.
SubscriberConfig	Configuration options for a Subscriber
TokioRuntime	An `AsyncRuntime` implementation backed by Tokio.

KafkaError	Respresents all errors.
Offset	Position for the offset when no initial value.

AsyncRuntime	An abstraction over asynchronous runtimes.
IntoConfig	IntoConfig builds a Config
MessageExt	Message extension methods for Kafka messages

noop_publisher_ack_handler	Awaits each future returned by the publisher ack handler.
noop_subscriber_ack_handler	Acknowledges each ack, if the result variant is an error, the error is propagated.

Exposes rdkafka's Config