Contents

type: kafka
topics:
  - "avro-complex-topic"
serialize_format: avro_with_schema_registry
schema_registry_url: "mock://embulk-input-kafka"
brokers:
  - "localhost:9092"
fetch_max_wait_ms: 1000
columns:
  - {name: id, type: string}
  - {name: int_item, type: long}
  - {name: varchar_item, type: string}
  - {name: time, type: long}
  - {name: array, type: json}
  - {name: data, type: json}
  - {name: _key, type: string}
  - {name: _partition, type: long}

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
embulk-input-kafka-0.1.0	src/test/resources/config_complex_avro.yml