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