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.