Overview
The interceptors field is an array. A Pipeline can have multiple interceptor configurations.
Currently, interceptors are divided into two types:
- source interceptor: running in the process of source sending data to queue
source -> source interceptor -> queue
. - sink interceptor: running in the process of queue to sink
queue -> sink interceptor -> sink
.
An interceptor belongs to only one of them. Most of the components are source interceptor, which supports configuring belongTo to be used by some sources. A few general properties such as retry interceptor are sink interceptor.
Interceptor Common Configuration
enabled
field | type | required | default | description |
---|
enabled | bool | false | true | whether to enable the interceptor |
name
field | type | required | default | description |
---|
name | string | false | | Indicates the name of the interceptor. When the same type of interceptor is configured in the pipeline, it is required to distinguish the identifier. |
belongTo
field | type | required | default | description |
---|
belongTo | string array | false | | Only the source interceptor can use to specify which sources the interceptor is used by. |
order
field | type | required | default | description |
---|
order | int | false | | The order of the interceptor |