Drop
The drop transform function drops a record from further processing.
Use in conjunction with when to selectively drop records.
The step name is drop, and the UserConfig is controlled here: {"steps": [{"type": "drop", "when": "value.firstName == value1"}]}.
Parameters:
| Parameter | Description |
|---|---|
when |
By default, the record is dropped. Set this parameter to selectively choose when to drop a message. |
Example
-
Produce an AVRO message with the payload:
{firstName: value1, lastName: value2}. -
The function drops records matching the
whenstatementvalue.firstName == value1.
There is no output.
What’s next?
For more, see Transform Functions or the Pulsar documentation.