Documentation
¶
Index ¶
- func CloseKafkaClient()
- func CreateTopic(broker string, topic string, partitions int, replicationFactor int) error
- func GetKafkaClient() (*kafka.AdminClient, error)
- func GetKafkaTopics() ([]string, error)
- func NewKafkaClient(config *kafka.ConfigMap) (*kafka.AdminClient, error)
- func SetKafkaClient(newClient *kafka.AdminClient)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CloseKafkaClient ¶
func CloseKafkaClient()
func CreateTopic ¶
func GetKafkaClient ¶
func GetKafkaClient() (*kafka.AdminClient, error)
func GetKafkaTopics ¶
func NewKafkaClient ¶
func NewKafkaClient(config *kafka.ConfigMap) (*kafka.AdminClient, error)
func SetKafkaClient ¶
func SetKafkaClient(newClient *kafka.AdminClient)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.