Fetcher INFO : Fetch offset .... is out of range for partition ..., resetting offset
试图了解发生这种情况时会发生什么。如果我们尝试读取的偏移量丢失了(我假设是因为kafka GC'ed了偏移量),auto.offset.reset = latest我们是否会跳过数据到最新的偏移量?
auto.offset.reset = latest
避免数据丢失的安全配置是什么?
apache-kafka spring-kafka
apache-kafka ×1
spring-kafka ×1