当我使用消费者高级api轮询来自kafka的数据时,它可能包含许多历史数据。如何设置从现在开始使用数据并抛出(或放弃)历史数据。有办法解决这个问题吗?Kafka版本:0.9.0.1。
bvjveswy1#
使用高级api意味着为您提供了自动偏移管理,您不必手动管理偏移。所以选中“auto.offset.reset”选项并将其设置为“最大”
1条答案
按热度按时间bvjveswy1#
使用高级api意味着为您提供了自动偏移管理,您不必手动管理偏移。所以选中“auto.offset.reset”选项并将其设置为“最大”