Overview

interceptors字段为数组,一个Pipeline中可填写多个interceptor组件配置。

目前,interceptor分为两种类型:

  • source interceptor:运行在source发送数据到queue的过程中,source -> source interceptor -> queue
  • sink interceptor:运行在queue到sink的过程中,queue -> sink interceptor -> sink

一个interceptor只属于其中一种。大部分组件为source interceptor类型,可支持配置belongTo被部分source使用。少数通用性质的比如retry interceptor为sink interceptor类型。

Interceptor通用配置

enabled

字段类型是否必填默认值含义
enabledbool非必填true表示是否开启该interceptor

name

字段类型是否必填默认值含义
namestring非必填表示interceptor的名称。当pipeline里配置相同type interceptor的情况下,必填,用于区分标识

belongTo

字段类型是否必填默认值含义
belongTostring数组非必填仅source interceptor可用,用于指定该interceptor仅被哪些source使用

order

字段类型是否必填默认值含义
orderint非必填interceptor的排列顺序权重