Spring 最新的云流2.0和startOffset
Spring cloud stream 2.0 and startOffset latest
在将我们的应用程序升级到 spring boot 2.0.3 时，我们遇到了消费消息和使用 startOffset: latest.
的问题
我们测试的场景如下：
- 将配置有
startOffset: latest 的消费者 (topic = TEST_CHANNEL,group = kafka2_test) 的应用程序部署到 pcf，并将实例数增加到 5。
- 停止应用程序
- 向 TEST_CHANNEL 主题发布 40 条消息
- 启动应用程序
我们可以看到应用已成功分配给分区，但是，某些实例不会从分配给它们的分区中使用。
我们还通过检查组的滞后来验证它。
这种情况在使用 spring boot 1.5.10 时有效。 在使用 spring boot 2.0.3 时也有效没有设置 startOffset: latest.
注意：这不是一个新的组，所以应该存在偏移量供消费者使用，resetOffsets应该没有任何影响。
这是 spring 引导 2.0.3 中的问题吗？
not a new group ... and resetOffsets should not have any effect.
resetOffsets 专门用于将现有组的偏移量重置为 startOffset 值。
在binder 1.3.x版本（Boot 1.5.x使用的版本）中被破解，没有效果
在将我们的应用程序升级到 spring boot 2.0.3 时，我们遇到了消费消息和使用 startOffset: latest.
的问题
我们测试的场景如下：
- 将配置有
startOffset: latest的消费者 (topic = TEST_CHANNEL,group = kafka2_test) 的应用程序部署到 pcf，并将实例数增加到 5。 - 停止应用程序
- 向 TEST_CHANNEL 主题发布 40 条消息
- 启动应用程序
我们可以看到应用已成功分配给分区，但是，某些实例不会从分配给它们的分区中使用。
我们还通过检查组的滞后来验证它。
这种情况在使用 spring boot 1.5.10 时有效。 在使用 spring boot 2.0.3 时也有效没有设置 startOffset: latest.
注意：这不是一个新的组，所以应该存在偏移量供消费者使用，resetOffsets应该没有任何影响。
这是 spring 引导 2.0.3 中的问题吗？
not a new group ... and
resetOffsetsshould not have any effect.
resetOffsets 专门用于将现有组的偏移量重置为 startOffset 值。
在binder 1.3.x版本（Boot 1.5.x使用的版本）中被破解，没有效果