kafka中每个聚合根事件的单个或多个主题（流）
共有1个答案
我不确定是否有正确/错误的问题，但以下是我的两便士价值：
- 我的经验法则是每个有界上下文的主题，以在易于管理和侦听器接收的事件数量之间取得平衡
- 事件无论如何都需要进行排序，以便它们以正确的顺序存储在EventStore中。向事件添加sequenceId并使用Resequencer（例如在Camel中）以确保侦听器以正确的顺序处理事件。
希望对你的项目有所帮助和帮助。
-
在构建Kafka Streams拓扑时，可以通过两种不同的方式对多个主题的读取进行建模： 读取具有相同源节点的所有主题。 选项1相对于选项2是否有相对优势，反之亦然？所有主题都包含相同类型的数据，并具有相同的数据处理逻辑。
-
我有2个Kafka的主题流完全相同的内容从不同的来源，所以我可以有高可用性的情况下，其中一个来源失败。我正在尝试使用Kafka Streams0.10.1.0将2个主题合并为1个输出主题，这样我就不会错过任何关于失败的消息，并且当所有源都启动时没有重复的消息。 当使用KStream的方法时，其中一个主题可以毫无问题地关闭（次要主题），但是当主主题关闭时，将不会向输出主题发送任何内容。这似乎是因为，
-
我们有一个传入的kafka主题，多个基于Avro模式的消息序列化到其中。 我们需要将Avro格式的消息拆分为多个其他kafka主题，基于某个公共模式属性的值。 想了解如何实现它，同时避免在汇流平台上构建中间客户端来进行这种拆分/路由。
-
我有一个在多个服务器上运行的剧本。所有服务器都需要指定密码，该密码特定于运行Playbook的每个用户。在运行playbook时，我不能使用，因为服务器上的sudo密码不同。这与另一个关于多个sudo密码的问题中的情况相同。 一个可行的解决方案是在中指定: 除了之外，每个主机还定义了其他变量。这些变量应该提交给git存储库。但是，由于特定于运行playbook的每个用户，所以我希望有一个单独的文件
-
问题内容： 通常，您需要显示数据库项目的列表以及有关每个项目的特定汇总号。例如，当您在“堆栈溢出”中键入标题文本时，将出现“相关问题”列表。该列表显示了相关条目的标题以及每个标题的响应数量的单个汇总数量。 我有一个类似的问题，但需要多个聚合。我想根据用户选项以3种格式中的任何一种显示项目列表： 我的商品的名称（共15个，我拥有的13个） 我的商品的名称（共15个） 我的商品的名称（我拥有13个）
-
配置的application.yaml如下所示。这个想法是我有3个输入和3个输出主题。该组件从input topic获取输入，并将输出提供给OutputTopic。 引发的异常为 谁能帮助我与Kafka Streams Spring-Kafka代码样本处理与多个输入和输出主题。 更新：2021年1月21日