Helpers for working with Kafka’s client API.
A client context that supports rewriting broker addresses.
ClientContextimplementation that uses
A simpler version of
create_new_client_configthat defaults the
INFOand should only be used in tests.
Retrieve number of partitions for a given
topicusing the given