在本地模式下运行代码（调用同一个kafka代理）很好，但是一旦我部署到集群，我就会发现这个奇怪的错误。有什么想法吗？
以下错误：
2014-09-17 16:59:55 s.k.KafkaUtils [WARN] Got fetch request with offset out of range: [300]; retrying with default start offset time from configuration. configured start offset time: [-1] offset: [5]2014-09-17 16:59:55 s.k.KafkaUtils [WARN] Got fetch request with offset out of range: [300]; retrying with default start offset time from configuration. configured start offset time: [-1] offset: [5]2014-09-17 16:59:55 s.k.KafkaUtils [WARN] Got fetch request with offset out of range: [300]; retrying with default start offset time from configuration. configured start offset time: [-1] offset: [5]2014-09-17 16:59:55 s.k.KafkaUtils [WARN] Got fetch request with offset out of range: [300]; retrying with default start offset time from configuration. configured start offset time: [-1] offset: [5]
1条答案
按热度按时间xmd2e60i1#
意思是你要求的补偿已经不存在了。。不知道我是不是错了，你用的是Kafka。。如果是，请尝试将“开始偏移时间”值从
-1至-2这将强制它从队列的开头读取。如果您使用的喷口实现与我提到的不同，那么请查找允许您从头开始阅读它的任何设置