Crate janus_kafka[−][src]

Janus-Kafka

Kafka adapter for Janus.

Macros

opts	`instrumented` Create an [`Opts`].

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`.
Opts	`instrumented` A struct that bundles the options for creating most `Metric` types.
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	`tokio-rt` An `AsyncRuntime` implementation backed by Tokio.

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

Message extension methods for Kafka messages

instrumented_publisher_ack_handler	`instrumented` Awaits each future returned by the ack handler and increments a metric. A convenience function to continuously processes acks until an error is encountered.
instrumented_subscriber_ack_handler	`instrumented` For each ack increments a metric depending on the variant in the result. A convenience function to continuously processes acks until an error is encountered.
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.