[−][src]Crate janus_kafka
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 |
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 | An |
Enums
KafkaError | Respresents all errors. |
Offset | Position for the offset when no initial value. |
Traits
AsyncRuntime | An abstraction over asynchronous runtimes. |
IntoConfig | IntoConfig builds a Config |
MessageExt | Message extension methods for Kafka messages |
Functions
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. |
Type Definitions
Config | Exposes rdkafka's Config |