juplo.de Git - demos/kafka/training/blob - datagen-source-connector.json

   1 {
   2   "connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
   3   "kafka.topic": "test",
   4   "value.converter": "io.confluent.connect.json.JsonSchemaConverter",
   5   "value.converter.schemas.enable": "true",
   6   "value.converter.schema.registry.url": "http://schema-registry:8085",
   7   "schema.string": "{\"type\":\"record\",\"name\":\"sampleschema\",\"fields\":[{\"name\":\"key\",\"type\":{\"type\":\"enum\",\"name\":\"Example_Key_Values\",\"symbols\":[\"a\",\"b\",\"c\",\"d\"]}},{\"name\":\"attribute_1\",\"type\":\"string\"},{\"name\":\"attribute_2\",\"type\":\"string\"}]}",
   8   "schema.keyfield": "key"
   9 }