卡夫卡订阅主题不确定性

抱歉标题不正确:

我的问题是,我有一个“动态”的卡夫卡框架,当用户请求一个新主题时,新的卡夫卡消费者的创建会立即发生。

问题是,我知道当消费者在X秒内没有返回新值时,我就完成了。

现在的问题是,当我创建新的消费者时,会在幕后发生很多事情,比如元数据注册等。所以我的公式中的值X需要非常高,否则我会停止处理,但消费者从未开始获得任何值。

有什么好办法解决这样的问题吗?

我知道有.poll(0);它等待元数据创建,但已被弃用

PS:我通过.poll(Duration.of(0))从消费者那里获取数据,因为我不想阻止等待,只对最新的数据感兴趣。我会自己循环调用.poll,间隔足够大。