Storm的Transactional Topology怎么配置
在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"]
相关文章