Client returns the kafkactl client.

ClientVersion returns the kafkactl client.

ClusterDetails prints details for the current context.

GetBrokerMetrics return broker related metrics.

GetMessages returns messages from a kafka topic.

GetMsgOffsets returns offsets for the given topics queried by time.

GetNonDefaultConfigs returns Topic Configs that have been altered.

GetTopicConfigs creates and returns Topic Configs.

MetricR returns the kafkactl metrics registry.

ParseTopicStdin parses Stdin passed from kafkactl topic metadata.

PrintMSG returns messages displayed by the desired format while following a topic.

SearchTopicConfigs searches and returns Topic Configs.

SetDefaultConfig sets the configuration for a Topic back to defaults.

SetTopicConfig sets a parameter for a Topic.

client variables.

FORCE bypasses any configured checks.

APIVersion describes an API Version Key and its Max Version.

MetricFlags defines flags for reporting metrics.

OffsetRangeMap contains Topics and a Range of Offsets specified from a beginning and end.

PartitionLag struct def:.

TopicConfig struct def:.

TopicConfigFlags .

TotalLag struct def:.