Storm的Transactional Topology怎么配置

2023-04-07 02:44:00 transactional 配置 storm

在Storm中,Transactional Topology的配置主要有两个部分:第一个部分是组件的配置,第二个部分是事务的配置。

组件配置主要指定了每个组件的ID,组件类型,以及组件的输入和输出。事务配置主要指定了事务ID,事务类型,以及事务的输入和输出。

下面是一个简单的Transactional Topology的配置示例:

组件配置:

component.id: "component1"

type: "spout"

class: "com.test.TestSpout"

inputs: ["transaction1"]

outputs: ["transaction2"]

事务配置:

transaction.id: "transaction1"

type: "commit"

class: "com.test.TestTransaction"

inputs: ["component1"]

outputs: ["component2"]

相关文章