Module kafka_threadpool::api

Public Library API calls

Modules

add_messages_to_locked_work_vec

Helper for locking the work Vec and draining all messages while locked

build_kafka_client_config

helper for building a static configuration KafkaClientConfig object from environment variables

build_kafka_publish_message

helper for building a supported KafkaPublishMessage message.

drain_messages_from_locked_work_vec

Helper for locking the work Vec and draining all messages while locked

get_kafka_producer

Create an rdkafka::producer::FutureProducer from a KafkaClientConfig

kafka_publish_message

class definition and implementation for KafkaPublishMessage

kafka_publish_message_type

enum for supported message types with the kafka_threadpool