当前位置: 首页 > 知识库问答 >
问题:

SCDF流图如何反映多个源通道?

贺立果
2023-03-14

如果有一个源应用程序(名为a-source),它有多个通道来发送消息,例如channelA。destination=b主题,channelB。destination=c主题。b-topic的接收者是b-link,c-topic的接受者是c-Sink。我如何构造我的流,像这样描述它们:A|B和A|C?如果是这样的话,我认为我的A源代码的一部分在每个流中都是有用的。

所以我的问题是:SCDF流DSL如何处理单源应用程序的多抽头。

共有1个答案

都建树
2023-03-14

可以在流 DSL 中使用命名通道目标。

例如:

数据流:

 类似资料:
  • 我已经阅读了文档,但我不清楚以下情况: 消费者在scdf之外,处理器和接收器在里面。 所有提供的示例,三个组件都在里面。 从我的角度来看,我认为有两种解决方案: SCDF外部的生产者在SCDF中配置的主题中生成消息 在SCDF之外有另一个绑定器,处理器/接收器连接到SCDF之外的这个绑定器 如果有人能提供任何样本,它将非常有用

  • 我正在遵循入门指南[1],但是我已经从配置设置中删除了MySQL和analytics的内容,因为我不打算使用任何分析函数。但是,scdf服务后来崩溃了,因为没有配置数据源。 好的,所以似乎仍然需要在scdf-config-kafka.yml[2]中配置数据源(尽管从阅读文档来看,我认为它只用于分析内容)。 但为了什么?数据源用于持久化Kafka消息,还是在节点之间建立云流消息? 我找不到任何关于大

  • 问题内容: 我有这样的课: 我想为每个MultiDataPoint生成 当然,在多个MultiDataPoints中,“键”可以相同。 因此,给定a ,如何使用Java 8流转换为? 这是我目前在没有流的情况下进行转换的方式: 问题答案: 这是一个有趣的问题,因为它表明有很多不同的方法可以达到相同的结果。下面我展示了三种不同的实现。 集合框架中的默认方法: Java 8向集合类中添加了一些与 St

  • 我正在用Stream学习Java,我有一张

  • 问题内容: 这是我的代码,但这是针对单个文件的解决方案。 我可以像下面的单个文件一样共享多个文件和上载吗? 问题答案: 是的,但是您需要使用而不是。 这绝对可以简化,但我在其中保留了一些内容,以便您可以分解所需的每个步骤。 更新 :从API 24开始,共享文件URI将导致FileUriExposedException。为了解决这个问题,您可以将compileSdkVersion切换为23或更低版本

  • 目前,我有一个react组件,需要在不同的按钮点击时调用同一组件的2个突变。 我正在使用从react组件与graph ql服务器进行交互。 如果我使用这个。道具。mutate要调用单击时的突变事件,没有选项/参数指定要调用的突变。 https://www.apollographql.com/docs/react/essentials/mutations.html 如果我直接使用这个。道具。muta