没办法的, kafka只有 按下标顺序读取的。
假如我不想跳过呢?本地的SubscriptionState里维持的offset有办法rollback么?
那建议你用官方的消费者测试一下,什么都不要改动,看看是否有同样的现象。
还是因为逻辑导致的。另外版本也要对应。
研究了下Fetcher的createFetchRequests方法(0.10),应该是else if (this.client.pendingRequestCount(node) == 0) 这个分支没有进去。。Apache kafka源码剖析里也没有找到想要的答案,愁死了。。