Module api 

Commonly-used API function(s), struct(s) and enum(s)

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_consumer

Create a rdkafka::consumer::BaseConsumer from a KafkaClientConfig

get_kafka_producer

Create a 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