Spring Cloud Kinesis Binder使用者组设置以避免重复记录的处理

问题描述

我正在使用Spring Cloud Kinesis活页夹，在使用消费者群体时遇到了问题

这是我的应用程序配置：

spring:
  cloud:
    stream:
      bindings:
        sample-binder:
          destination: sample-destination
          group: sample-group
          content-type: application/json
        sample-binder-2:
          destination: sample-destination-2
          group: sample-group-2
          content-type: application/json

Kinesis有2个分片，并且2个应用程序实例当前正在运行。

我看到的问题是两个应用程序实例都在处理所有记录，这意味着将消耗重复的记录。

有人可以帮助我做错什么，如何在许多应用程序实例上实现记录处理的平均分配，并实现正确的配置以实现排序？

解决方法

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

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

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