Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Initialize ¶
func Initialize() error
TODO: Broker connection close logic
defer func() { if err := kafka.Close(); err != nil { panic(err) } }()
Types ¶
type KafkaStruct ¶
type KafkaStruct struct { AdminClient *kafka.AdminClient L *sync.RWMutex }
func GetInstance ¶
func GetInstance() (*KafkaStruct, error)
func (*KafkaStruct) DeleteTopics ¶
func (k *KafkaStruct) DeleteTopics(topics []string) error
func (*KafkaStruct) GetAllTopics ¶
func (k *KafkaStruct) GetAllTopics() []string
Click to show internal directories.
Click to hide internal directories.