- 一、构建Kafka消费者
- 二、获取topic分区信息
- 三、订阅topic
- 四、获取topic可以消费的开始分区信息
- 五、获取topic可以消费的最大分区信息
- 六、获取消费起始的时间戳
- 七、获取消费截止的时间戳
- 八、得到指定起始时间的offset
- 九、得到指定截止时间的offset
- 十、消费指定分区
#构建消费者
kafkaBrokers = ["10.34.66.114:9092", "10.34.66.17:9092", 
#构建消费者
kafkaBrokers = ["10.34.66.114:9092", "10.34.66.17:9092",