apache-kafka - 当我使用 Kafka Streams 时，我很困惑，我应该如何指定主题分区的偏移量以供消费？

Question

例如.我有一个有4个分区的主题“测试”。当我启动流应用程序时，一段时间后，应用程序崩溃。我想指定消费的偏移量，我想在最后一次读取后从偏移量消费数据。但我找不到任何可以帮助使用 kafka-streams api 实现它的东西。

PS我们使用的是kafka-2.1.0

标签： apache-kafkaoffsetapache-kafka-streams