Crate janus_kafka 

Janus-Kafka

Kafka adapter for Janus.

Macros

optsinstrumented

Create an [Opts].

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.

Optsinstrumented

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

TokioRuntimetokio-rt

An AsyncRuntime implementation backed by Tokio.

Enums

KafkaError

Respresents all errors.

Offset

Position for the offset when no initial value.

Traits

MessageExt

Message extension methods for Kafka messages

Functions

instrumented_publisher_ack_handlerinstrumented

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_handlerinstrumented

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.