项目中最近使用kafka需要定时清理消息，我们知道kafka有周期性清理消息机制,但是项目中往往因为数据量较大，需要手动控制分区已消费消息的清理。 此处使用的是反编译程序，具体几个方法已标出， ...

查看kafka版本信息 find /opt/kafka/libs/ -name \*kafka_\* | head -1 | grep -o '\kafka[^\n]*' 示例：kafka/lib ...

本次的记录内容包括： 1.Java调用生产者APi流程 2.Kafka生产者Api的使用及说明 3.Kafka消费者Api的使用及说明 4.Kafka消费者自动提交Offset和手动提交Off ...