Selector 选择器

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

复制模式
属性说明:
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案例
原文地址:https://www.cnblogs.com/zpb2016/p/5766925.html