问题描述
我有一个关于在 kafka 中发布和读取消息的方式的问题，用于具有多个相同微服务实例的微服务架构用于写入和读取。 我的主要问题是发布和读取的微服务配置了自动缩放功能，但默认实例数为 1。
关键是我有一个实体，我们称之为“事件”，存储在 DDBB 中，每个实体在 DDBB 中都有自己的 ID。当在特定实体中执行某些特定命令（假设使用 entityID = ajsha87）时，它必须发布一条消息，该消息将由消费者读取。如果同一实体的每条消息都写在不同的分区中并同时使用（并发问题），我会遇到很多问题。
我的问题是，例如，我是否可以根据 entityID 设置在哪个分区中发布此特定实体的所有事件。对于具有不同 ID 的另一个实体，我不关心分区，但同一实体的消息必须始终发布在同一分区中，以避免消费者读取消息 (1) 之后发布的消息 (2)。 有什么机制可以做到这一点，或者每次我保存实体时，我都会在 DDBB 中随机存储分区 ID，将在其中发布消息？
消费者也是如此。只有一个消费者可以同时读取一个分区，因为如果不是，则编号为 1 的消费者可以从与实体 (ID=78198) 关联的分区 (1) 中读取消息 (1)，然后另一个可以从中读取消息 (2)分区 (1) 与同一实体关联并在第一个之前处理消息 2。
根据微服务自动伸缩，每个实例只订阅一个分区有什么机制吗？
另一个选项是为每个新的发布者实例动态分配一个分区，但我不知道如何动态配置它以根据微服务实例设置不同的分区 ID
顺便说一下，我正在使用弹簧靴
感谢您的回答和推荐，如果我的英语不够好，请见谅。
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）