admin

Documentation

Index

• type Client
• type Config
• type CreateTopicConfig
• type ReplicaAssignment

Types

type Client

type Client interface {
	Close()
	CreateTopic(context.Context, CreateTopicConfig) error
}

Client is an admin client.

type Config

type Config struct {
	Type             string
	BootstrapServers string
	SSLCALocation    string
	SecurityProtocol string
	SASLMechanism    string
	SASLUsername     string
	SASLPassword     string
}

type CreateTopicConfig

type CreateTopicConfig struct {
	Name              string
	Partitions        int
	ReplicationFactor int
	Config            map[string]string
	ReplicaAssignment ReplicaAssignment
}

CreateTopicConfig holds CreateTopic parameters.

type ReplicaAssignment

type ReplicaAssignment [][]int32