选择器可以工作在复制 多路复用(路由) 模式下

复制模式
属性说明:
selector.type replicating 类型名称,必须是 replicating 
selector.optional 标志通道为可选
案例:
参看avro sink案例
多路复用(路由)模式
属性说明:
selector.type 类型,必须是"multiplexing"
selector.header 指定要监测的头的名称  
selector.default  
selector.mapping.*
举例:
a1.sources = r1
a1.channels = c1 c2 c3 c4
a1.sources.r1.selector.type = multiplexing
a1.sources.r1.selector.header = state
a1.sources.r1.selector.mapping.CZ = c1
a1.sources.r1.selector.mapping.US = c2 c3
a1.sources.r1.selector.default = c4
案例:
参看 avro sink案例

相关文章:

  • 2022-12-23
  • 2021-01-15
  • 2022-01-16
  • 2021-12-20
  • 2021-10-05
  • 2021-05-24
  • 2022-12-23
  • 2022-12-23
猜你喜欢
  • 2021-04-06
  • 2022-01-21
  • 2021-09-13
  • 2022-02-17
  • 2021-05-23
  • 2022-12-23
相关资源
相似解决方案