Avro Serializer
The Avro Serializer operator converts CSV encoded lines and produces the contents as Avro encoded messages. It does not support nested records.
Configuration Parameters
|
Parameter |
Type |
Description |
|---|---|---|
|
avroSchema
|
string |
Avro schema used to read fields names and types. Default: "" |
|
delimiter |
rune |
Ascii code for delimiter character, the default is ","
code.
Default: 44 |
| headerIncluded |
bool |
Used to indicate if there is a header on CSV first line. Default: true |
|
includeSchema |
bool |
The schema should be included on avro message.
Default: false |
Input
|
Input |
Type |
Description |
|---|---|---|
|
in |
message |
CSV encoded message. |
Output
|
Output |
Type |
Description |
|---|---|---|
|
out |
message |
Avro representation of the input message. |