# Packages
No description provided by the author
# Functions
NewClient returns a KafkaAdmin.
NewClientWithFactory returns a new admin Client using a factory func for the kafkaAdminClient.
No description provided by the author
NewTopicState initializes a TopicState.
NewTopicStates initializes a TopicStates.
No description provided by the author
# Variables
ErrNoData is a generic error for no data available to be returned.
SASLMechanismSet is the set of mechanisms supported for client to broker authentication.
SecurityProtocolSet is the set of protocols supported to communicate with brokers.
# Structs
BrokerThrottleConfig defines an inbound and outbound throttle rate in bytes to be applied to a broker.
Client implements a KafkaAdmin.
Config holds Client configuration parameters.
CreateTopicConfig holds CreateTopic parameters.
ErrorFetchingMetadata is an error encountered fetching Kafka cluster metadata.
ErrRemoveThrottle is a generic error for RemoveThrottle.
ErrSetThrottle is a generic error for SetThrottle.
PartitionState describes the state of a partition.
RemoveThrottleConfig holds lists of all topics and brokers to remove throttles from.
SetThrottleConfig holds SetThrottle configs.
TopicState describes the current state of a topic.
# Interfaces
KafkaAdmin interface.
# Type aliases
No description provided by the author
ReplicaAssignment is a [][]int32 of partition assignments.
ResourceConfigs is a map of resource name to a map of configuration name and configuration value Example: map["my_topic"]map["retention.ms"] = "4000000".
TopicStates is a map of topic names to TopicState.