admin

Documentation

Index

• type Admin
• type Config
  • func DefaultKafkaConfig() Config
  • func RawKafkaConfig(key string) Config
  • func StdKafkaConfig(name string) Config
  • func (config *Config) Build() *Admin

Types

type Admin

type Admin struct {
	*kafka.AdminClient
}

type Config

type Config struct {
	KafkaConfig kafkaConfig `json:"kafka_config"`
	// contains filtered or unexported fields
}

func DefaultKafkaConfig

func DefaultKafkaConfig() Config

func RawKafkaConfig

func RawKafkaConfig(key string) Config

RawKafkaConfig ...

func StdKafkaConfig

func StdKafkaConfig(name string) Config

StdKafkaConfig ...

func (*Config) Build

func (config *Config) Build() *Admin

Build ...