shove 0.10.4

Async tasks via pubsub on steroids. Comes with built-in support for complex queue configurations, audit logs, autoscaling consumer groups and more.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

pub mod autoscaler;
mod backend;
mod client;
mod constants;
mod consumer;
mod consumer_group;
#[cfg(feature = "kafka-msk-iam")]
mod msk_iam;
mod publisher;
mod topology;

pub use autoscaler::{
    KafkaAutoscalerBackend, KafkaLagStatsProvider, KafkaQueueStats, KafkaQueueStatsProvider,
};
pub use client::{KafkaClient, KafkaConfig};
#[cfg(feature = "kafka-ssl")]
pub use client::{KafkaSasl, KafkaTls};
pub use consumer::KafkaConsumer;
pub use consumer_group::{
    KafkaConsumerGroup, KafkaConsumerGroupConfig, KafkaConsumerGroupRegistry,
};
pub use publisher::KafkaPublisher;
pub use topology::KafkaTopologyDeclarer;