例如。我有一个主题“ test”，带有4个分区。当我启动流应用程序时，过了一段时间，应用程序崩溃了。我想指定消耗量的偏移量，我想在偏移量后消耗数据最后阅读。 但是我找不到使用kafka-streams api可以帮助实现这一目标的任何东西。
P.S。我们正在使用kafka-2.1.0
qqwainier1 回答：当我使用Kafka Streams时，我很困惑，如何指定要消费的topic-partition的偏移量？
暂时没有好的解决方案，如果你有好的解决方案，请发邮件至：iooj@foxmail.com