更换group.id时kafka从哪开始消费

设置消费者properties的两个参数 consumer.group.id properties.setProperty("auto.offset.reset", "earliest”) // latest 注意: 只要不更改group.id,每次重新消费kafka,都是从上次消费结束的地方继续开始,不论"auto.offset.reset”属性设置的是什么   场景一:Kafka上在实时被灌入
相关文章
相关标签/搜索