admin

package
v0.0.0-...-b937326 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 27, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 ...

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL