Module mz_kafka_util::client
source · [−]Expand description
Helpers for working with Kafka’s client API.
Structs
A ClientContext
implementation that uses tracing
instead of log
macros.
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