Documentation
¶
Index ¶
- func GetBroker(zk string) (brokers []string, err error)
- func GetKafkaController(zkUrl string) (controller string, err error)
- func GetProducer(broker []string, topic string) (writer *kafka.Writer, err error)
- func InitTopic(zkUrl string, topics ...string) (err error)
- func NewConsumer(ctx context.Context, zkUrl string, groupId string, topic string, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetKafkaController ¶
func GetProducer ¶
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.