kafka从当前时间获取数据

waxmsbnn  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(495)

当我使用消费者高级api轮询来自kafka的数据时,它可能包含许多历史数据。
如何设置从现在开始使用数据并抛出(或放弃)历史数据。有办法解决这个问题吗?
Kafka版本:0.9.0.1。

bvjveswy

bvjveswy1#

使用高级api意味着为您提供了自动偏移管理,您不必手动管理偏移。所以选中“auto.offset.reset”选项并将其设置为“最大”

相关问题