Filters
Following variables need to be set to enable JSON/JEXL filters.
FILTER_ENGINE
Defines whether to use JSON
Schema-based filters or JEXL
-based filters or NO_OP
(i.e. no filtering)
- Example value:
JSON
- Type:
optional
- Default value
: NO_OP
FILTER_JSON_ESB_MESSAGE_TYPE
Defines the format type of the input ESB messages, i.e. JSON/Protobuf. This field is required only for JSON filters.
- Example value:
JSON
- Type:
optional
FILTER_SCHEMA_PROTO_CLASS
The fully qualified name of the proto schema so that the key/message in Kafka could be parsed.
- Example value:
com.raystack.esb.driverlocation.DriverLocationLogKey
- Type:
optional
FILTER_DATA_SOURCE
key
/message
/none
depending on where to apply filter
- Example value:
key
- Type:
optional
- Default value
: none
FILTER_JEXL_EXPRESSION
JEXL filter expression
- Example value:
driverLocationLogKey.getVehicleType()=="BIKE"
- Type:
optional
FILTER_JSON_SCHEMA
JSON Schema string containing the filter rules to be applied.
- Example value:
{"properties":{"order_number":{"const":"1253"}}}
- Type:
optional