Demo Logs
📥 Count The total number of lines to output.
- optional: Indicates whether the parameter is optional.
- uint: Specifies the data type for this parameter.
- default: 9.223372036854776e+18 (Infinitely by default).
📥 Decoding (decoding) Configure how events are decoded from raw bytes.
- decoding.avro: Apache Avro-specific encoder options (required when codec is "avro").
- schema: Avro schema definition (required).
- strip_schema_id_prefix: Remove the schema ID prefix from Confluent Kafka messages (true/false).
- decoding.codec (default: bytes): The codec to use for decoding events. Options include:
- avro: Decodes as Apache Avro.
- bytes: Uses the raw bytes as-is.
- gelf: Decodes as a GELF message.
- influxdb: Decodes as InfluxDB Line Protocol.
- json: Decodes as JSON.
- native: Decodes as native Protocol Buffers.
- native_json: Decodes as native JSON format.
- protobuf: Decodes as Protobuf.
- syslog: Decodes as Syslog.
- vrl: Decodes the raw bytes as input to a VRL program.
- decoding.gelf: GELF-specific decoding options (relevant when codec is "gelf").
- lossy: Determines whether to replace invalid UTF-8 sequences (true/false). Default: true.
- decoding.influxdb: InfluxDB-specific decoding options (relevant when codec is "influxdb").
- lossy: Determines whether to replace invalid UTF-8 sequences (true/false). Default: true.
- decoding.json: JSON-specific decoding options (relevant when codec is "json").
- lossy: Determines whether to replace invalid UTF-8 sequences (true/false). Default: true.
- decoding.native_json: Worker's native JSON-specific decoding options (relevant when codec is "native_json").
- lossy: Determines whether to replace invalid UTF-8 sequences (true/false). Default: true.
- decoding.protobuf: Protobuf-specific decoding options (relevant when codec is "protobuf").
- desc_file: Path to the protobuf descriptor set file.
- message_type: Fully qualified message type for serializing.
- decoding.syslog: Syslog-specific decoding options (relevant when codec is "syslog").
- lossy: Determines whether to replace invalid UTF-8 sequences (true/false). Default: true.
- decoding.vrl: VRL-specific decoding options (required when codec is "vrl").
- source: VRL program to decode the message (required).
- timezone: Timezone for timestamp conversion (optional).
📥 Framing (framing) Configure how byte streams are split into messages.
- method (default: bytes): Select the framing strategy. Options include:
- bytes
- character_delimited
- chunked_gelf
- length_delimited
- newline_delimited
- octet_counting
- Framing-specific settings:
- character_delimited:
- delimiter: ASCII character to separate frames (required).
- max_length: Max size of a frame.
- chunked_gelf:
- decompression: Options for decompression (Auto, Gzip, Zlib, None).
- max_length, pending_messages_limit, timeout_secs.
- length_delimited:
- length_field_is_big_endian: Whether the length field is big-endian (default: true).
- length_field_length, length_field_offset, max_frame_length.
- newline_delimited and octet_counting:
- max_length: Max size of a frame.
📥 Interval Time to pause between each batch of output lines.
- default: 1 second (default). Set to 0.0 for no delay.
📥 Lines List of lines to output (relevant when format = "shuffle").
- required: Specifies the required input.
📥 Sequence If true, each output line starts with an increasing sequence number, beginning with 0.
- default: False (default). Relevant when format = "shuffle".
