是否可以从 kafka 主题中的特定偏移量开始运行 kstream 应用程序?

问题描述

我在 springboot 中的 kafka 流应用程序中工作,这里我们只读取从第 0 个偏移量到现在的消息,

所以现在我有一个用例,如果我需要从第 10000 个偏移量或任何特定时间戳之后使用,我们如何在 kstreams 应用程序中执行此操作?

在普通消费者中,我们可以使用seek方法从特定的偏移量中消费,但我们如何在kstreams应用程序中做同样的事情?

有人能克服这种情况吗?

如果你能分享你对此的想法会很有帮助......

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)