📄️ Eval Node
The Eval node is a powerful transformation component in ZephFlow that applies expressions to modify, filter, or enrich incoming events. It uses the Fleak Eval Expression Language (FEEL) to transform d
📄️ Filter Node
The `filter` node allows you to selectively process events in your ZephFlow pipeline based on specific conditions. It evaluates each incoming event against an expression written in the Fleak Eval Expr
📄️ Assertion Node
The `assertion` node allows you to validate data flowing through your ZephFlow pipeline against specified conditions. It evaluates each incoming event against an expression written in the Fleak Eval E
📄️ Parser Node
The `parser` node is a versatile component in ZephFlow that extracts structured data from string fields in your events. It can parse various log formats into structured key-value pairs, allowing you t
📄️ Kafka Source Node
The `kafkaSource` node in ZephFlow enables you to consume data from Kafka topics, providing a seamless integration point for processing streaming data from Kafka in your data pipelines.
📄️ Kafka Sink Node
The `kafkaSink` node in ZephFlow enables you to publish processed data to Kafka topics, providing a seamless integration point for sending data from your pipeline to Kafka streams.
📄️ S3 Sink Node
The `s3Sink` node in ZephFlow enables you to write processed data to Amazon S3 (or S3-compatible storage) with built-in batching, date-partitioned keys, and multiple encoding formats.