type: kafka topic: "avro-complex-topic" acks: all retries: 3 brokers: - "localhost:9092" schema_registry_url: "mock://embulk-output-kafka" 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"}}, ]}}, ]