Module mz_kafka_util::client

source ·
Expand description

Helpers for working with Kafka’s client API.

Structs

A client context that supports rewriting broker addresses.
A ClientContext implementation that uses tracing instead of log macros.

Statics

CALLSITE 🔒
CALLSITE 🔒
CALLSITE 🔒
CALLSITE 🔒
CALLSITE 🔒
CALLSITE 🔒
CALLSITE 🔒
CALLSITE 🔒
CALLSITE 🔒
META 🔒
META 🔒
META 🔒
META 🔒
META 🔒
META 🔒
META 🔒
META 🔒
META 🔒

Functions

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".
A simpler version of create_new_client_config that defaults the log_level to INFO and should only be used in tests.
Retrieve number of partitions for a given topic using the given client