springcloudstream2.0和startoffset最新版本

rslzwgfq 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(421)

在将我们的应用程序升级到springboot2.0.3的过程中，我们遇到了一个消费消息和使用 startOffset: latest .
我们测试的场景如下：
部署消费者（topic=test\u channel，group=kafka2\u test）配置为 startOffset: latest 并将示例数增加到5。
停止应用程序
发布40条消息测试频道主题
启动应用程序
我们可以看到，应用程序成功地分配给分区，但是，一些示例并不使用它们分配给的分区。
我们还通过检查组的滞后来验证它。
当使用springboot1.5.10时，这个场景起作用了。当使用SpringBoot2.0.3而不设置 startOffset: latest .
注意：这不是一个新组，因此假设存在偏移量供使用者使用，并且 resetOffsets 不应该有任何影响。
这是SpringBoot2.0.3中的问题吗？