admin

type Client interface {
	CreateTopic(ctx context.Context, partitions int32, replicationFactor int16, configs map[string]*string, topic string) (kadm.CreateTopicResponse, error)
	ListEndOffsets(ctx context.Context, topics ...string) (kadm.ListedOffsets, error)
	ListTopics(ctx context.Context, topics ...string) (kadm.TopicDetails, error)
}

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