Sha256: c5c749ef7dd7e6d7584699f678b372c2309e08acb488623f851949501403ed67
Contents?: true
Size: 1.18 KB
Versions: 8
Compression:
Stored size: 1.18 KB
Contents
in:
type: file
path_prefix: ./src/test/resources/in_complex
parser:
charset: UTF-8
newline: CRLF
type: csv
delimiter: "\t"
quote: "\0"
escape: "\0"
null_string: 'NULL'
skip_header_lines: 1
columns:
- {name: 'id', type: string}
- {name: 'int_item', type: long}
- {name: 'time', type: timestamp, format: "%Y-%m-%dT%H:%M:%S"}
- {name: 'array', type: json}
- {name: 'data', type: json}
out:
type: kafka
topic: "avro-complex-topic"
acks: all
retries: 3
brokers:
- "localhost:9092"
schema_registry_url: "http://localhost:48081/"
serialize_format: avro_with_schema_registry
other_producer_configs:
buffer.memory: "67108864"
avsc:
type: record
name: ComplexRecord
fields: [
{name: "id", type: "string"},
{name: "int_item", type: "long"},
{name: "time", type: "long", logicalType: "timestamp-milli"},
{name: "array", type: {type: "array", items: "long"}},
{name: "data", type: {type: "record", name: "InnerData", fields: [
{name: "hoge", type: "string"},
{name: "aaa", type: ["null", "string"]},
{name: "array", type: {type: "array", items: "long"}},
]}},
]
Version data entries
8 entries across 8 versions & 1 rubygems