* 获取kafka消费组最大可用偏移量 */.

* 接收消费消息 * * param topic 主题 * param groupId 消费组名称 * param batchSize 批量消费数量 * param batchInterval 批量消费间隔时间 * param callback 获取消息回调函数 */.

* 发送生产消息 * * param topic 主题 * param text 发送消息内容 */.

类型：获取消息回调函数.