Module kafka_threadpool::kafka_publisher
source · [−]Expand description
Clients using kafka_threadpool get a
KafkaPublisher object when calling
start_threadpool(). The
KafkaPublisher is how
callers interface with the kafka_threadpool’s
lockable work Vec called publish_msgs
and can gracefully shutdown the threadpool.
Example for shutting down the threadpool:
my_kafka_publisher.shutdown().await.unwrap();Structs
KafkaPublishMessage