kafka

Documentation

Index

• func Initialize() error
• type KafkaStruct
  • func GetInstance() (*KafkaStruct, error)
  • func (k *KafkaStruct) DeleteTopics(topics []string) error
  • func (k *KafkaStruct) GetAllTopics() []string

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