Documentation ¶
Index ¶
Constants ¶
View Source
const ( Partition = 0 ConsumeRetryLimit = 5 Broker = "log-client" )
Variables ¶
View Source
var ( // ErrNoData is the err type for no data. ErrNoData = kafka.ErrNoData )
Functions ¶
func NewConsumer ¶
NewConsumer create a new cosumer to the special topic
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.