admin

package

v0.0.0-...-55ff922 Latest Latest Go to latest Published: Jul 24, 2026 License: BSD-3-Clause Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Admin struct {
	// contains filtered or unexported fields
}

func NewAdmin(client sarama.Client, clusterAdmin sarama.ClusterAdmin) *Admin

func NewFromConfig(cfg *config.Config, clusterName string) (*Admin, func(context.Context) error, error)

func (a *Admin) AlterTopicPartitions(topic string, numPartitions int32) error

func (a *Admin) CreateTopic(topic string, numPartitions int32, replicationFactor int16) error

func (a *Admin) DeleteConsumerGroups(groups ...string) error

func (a *Admin) DeleteTopics(topics ...string) error

func (a *Admin) DescribeCluster() error

func (a *Admin) DescribeConsumerGroup(group string) error

func (a *Admin) DescribeTopic(topic string) error

func (a *Admin) GetOffsets(topic string) error

func (a *Admin) ListConsumerGroupIDs() ([]string, error)

func (a *Admin) ListConsumerGroupLag(group string, topic string) error

func (a *Admin) ListConsumerGroupOffsets(group string, topic string) error

func (a *Admin) ListConsumerGroups() error

func (a *Admin) ListTopicNames() ([]string, error)

func (a *Admin) ListTopics() error