Documentation ¶
Overview ¶
kafka @author LanguageY++2013 2023/5/11 10:53 @company soulgame
kafka @author LanguageY++2013 2023/5/11 09:42 @company soulgame
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAsyncProducer ¶
func NewAsyncProducer(brokerList []string) (producer sarama.AsyncProducer)
func RegisterConsumerFromBeginning ¶
func RegisterConsumerFromBeginning(consumer sarama.ConsumerGroupHandler, brokerList []string, topics []string, group string)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.