Ø kafka_close() 关闭consumer连接 Ø kafka_commit() 提交当前consumer offset的位置 Ø kafka_offset() 设置消费组当前主题分区的位移 Ø kafka_open() kafka
