配置ReplyingKafkaTemplate以获取多个主题的响应
我有一个要求，即我必须使用Kafka的同步请求-应答模式，因此我正在使用ReplyingKafkatTemplate。
作为实现的一部分，有一个生产者在一个主题（input-message-topic1）上推送请求消息，但作为回报，我期待来自两个主题（output-message-topic1和output-message-topic2）的响应，我必须进一步聚合和处理。
问题：是否可以使用ReplyingKafkaTemplate/AggregatingReplyingKafkaTemplate或任何其他使用Kafka同步请求-应答模式的实现来实现上述场景？
共有1个答案
是的，AggregatingReplyingKafkatTemplate将执行此操作；只需将其侦听器容器配置为使用这两个主题；回复必须包含相关id标头（用于聚合）。
-
这是我发布的另一个问题的延续。以下是之前问题的链接：来自多个主题的消息聚合 我的要求是确保node1应该接收响应R1M1 实施的事情： > 设置Kafka领导人。来自两个节点的生产者记录中的相关ID。 KafkCamessageListenerContainerBean使用容器属性中的两个响应主题创建。ContainerProperties ContainerProperties=新的Contai
-
我有2个服务（都是在kotlin上的Spring引导）。将其命名为“客户机”和“服务器”，由于某些限制，我必须使用Kafka同步请求-应答模式。所以我尝试使用ReplyingKafkatemplate。我的问题是我需要为多个实体使用。意味着创建多个ReplyingKafkaTemplate，一个用于“foo”，第二个用于“bar”。因此，在我的代码中，我用setup创建了多个KafkaConfig
-
问题内容： 我正在发出HTTP请求并侦听“数据”： 问题在于响应是分块的，因此“数据”只是发送回的一部分内容。 我如何将全身退回？ 问题答案：
-
此配置适用于所有 基本主题。 常用配置 日间模式 - 夜间模式 classic 主题默认提供了对日间模式和夜间模式的支持，并在导航条上提供了切换开关。 通过以下配置可以自定义各模式：docusaurus.config.js module.exports = { // ... themeConfig: { // ... colorMode: { // "
-
我需要创建一个消费者，能够从多个主题拉和订单消息相对于时间戳（Kafka消息时间戳） 在本例中，我订阅了“主题A”和“主题B”，并按照时间戳的顺序对消息进行排队 现在，只要所有主题只有一个分区，这很容易用这个伪代码来解决： 当我为每个主题引入多个分区时，问题就出现了。显然，不可能将多个主题按时间顺序排序到一个流中，因为在一个主题中，顺序不能保证，只能在一个分区中，所以新的问题是将多个主题排序到具有
-
配置插件 暂时只支持配合vux-loader使用。 注意的是主题文件不能引入其他less文件，只能为简单变量列表。 请配置vux-loader的less-theme插件，指定用以覆盖的less文件路径： { name: 'less-theme', path: 'src/styles/theme.less' // 相对项目根目录路径 } 可配置颜色 源码地址：https://github.