kafka_offset ()

描述： 设置消费组当前主题分区的位移。 语法： kafka_offset(fd, offset) kafka_offset(fd, offset,[partition1, partition2,…]) kafka_offset(fd, [p消费组,主题分区,位移