Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetMessageLastOffset ¶
* 获取kafka消费组最大可用偏移量
func ReceiveMessage ¶
func ReceiveMessage(topic, groupId string, batchSize int32, batchInterval time.Duration, callback ConsumerCallback) error
* 接收消费消息 * * param topic 主题 * param groupId 消费组名称 * param batchSize 批量消费数量 * param batchInterval 批量消费间隔时间 * param callback 获取消息回调函数
func SendMessage ¶
* 发送生产消息 * * param topic 主题 * param text 发送消息内容
Types ¶
Source Files
Click to show internal directories.
Click to hide internal directories.