Crate janus_kafka[−][src]
Janus-Kafka
Kafka adapter for Janus.
Macros
opts | instrumented Create an [ |
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 |
Opts | instrumented A struct that bundles the options for creating most |
PublisherAcker | Acknowledges messages from the Publisher. |
PublisherConfig | Configuration options for a Publisher |
PublisherMessage | A |
SubscriberAcker | Acknowledges messages from the Subscriber. |
SubscriberConfig | Configuration options for a Subscriber |
TokioRuntime | tokio-rt An |
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_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. |