0
当我使用消费者高级API轮询来自Kafka的数据时，它可能包含许多历史数据。kafka从当前时间获取数据
如何从现在开始设置消耗数据并抛出（或放弃）历史数据。有什么办法可以解决这个问题吗？
卡夫卡版本：0.9.0.1。
A
回答
3
使用高级API意味着为您提供自动偏移管理，您不必手动管理偏移量。因此检查选项'auto.offset.reset'并将其设置为'最大'
相关问题
- 1. 基于当前时间从数据库获取数据PHP
- 2. 从网站获取当前时间
- 3. 获取当前时间？
- 4. FreeRTOS获取当前时间
- 5. 获取当前时间jPlayer
- 6. 获取当前时间（秒）和整数
- 7. 如何从当前时间获取获取时区？
- 8. 基于当前时间戳从sqlite数据库中获取数据
- 9. 从当前月份获取数据
- 10. 从KendoUI获取当前数据TreeView
- 11. iPhone - 问题NSDate根据当前时区获取时间间隔
- 12. 如何从00:00到当前时间获取今日时间？
- 13. 从当前时间戳获取日期时间默认
- 14. 用oracle数据库获取当前提交时间
- 15. 如何使用jooq获取数据库当前时间API
- 16. 获取当前时间并插入数据库
- 17. 获取数据库服务器的当前时间
- 18. 从unix时间获取当前时区的小时
- 19. 获取时间相关的数据，其中包括当前时间
- 20. 如何获取NSIS中的当前时间（当地时间）？
- 21. 从kafka-Spark-Streaming读取数据时获得空集
- 22. 如何获取python当前时间？
- 23. 获取当前时间串SWIFT 3.0
- 24. 正在获取当前时间
- 25. 无时间获取当前日期
- 26. 获取当前系统日期时间
- 27. XSLT 1.0获取当前日期时间
- 28. 如何获取当前的TAI时间？
- 29. 获取当前系统时间
- 30. 获取当前时间错误