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

fieldtyperequireddefaultdescription
enabledboolfalsetruewhether to enable the interceptor

name

fieldtyperequireddefaultdescription
namestringfalseIndicates the name of the interceptor. When the same type of interceptor is configured in the pipeline, it is required to distinguish the identifier.

belongTo

fieldtyperequireddefaultdescription
belongTostring arrayfalseOnly the source interceptor can use to specify which sources the interceptor is used by.

order

fieldtyperequireddefaultdescription
orderintfalseThe order of the interceptor