util

Documentation

Index

• func GetBroker(zk string) (brokers []string, err error)
• func GetTopicConfig(configMap map[string][]kafka.ConfigEntry, topic string) []kafka.ConfigEntry
• func InitTopic(zkUrl string, configMap map[string][]kafka.ConfigEntry, topics ...string) (err error)
• func InitTopicWithConfig(kafkaUrl string, configMap map[string][]kafka.ConfigEntry, numPartitions int, ...) (err error)

Functions

func GetBroker

func GetBroker(zk string) (brokers []string, err error)

func GetTopicConfig

func GetTopicConfig(configMap map[string][]kafka.ConfigEntry, topic string) []kafka.ConfigEntry

func InitTopic

func InitTopic(zkUrl string, configMap map[string][]kafka.ConfigEntry, topics ...string) (err error)

func InitTopicWithConfig

func InitTopicWithConfig(kafkaUrl string, configMap map[string][]kafka.ConfigEntry, numPartitions int, replicationFactor int, topics ...string) (err error)