Module mz_kafka_util::client

Helpers for working with Kafka’s client API.

Structs

BrokerRewritingClientContext

A client context that supports rewriting broker addresses.

MzClientContext

A ClientContext implementation that uses tracing instead of log macros.

Functions

create_new_client_config

Build a new rdkafka ClientConfig with its log_level set correctly based on the passed through tracing::Level. This level should be determined for target: "librdkafka".

create_new_client_config_simple

A simpler version of create_new_client_config that defaults the log_level to INFO and should only be used in tests.

get_partitions

Retrieve number of partitions for a given topic using the given client