Die Testdaten werden mit einem Record-Key erzeugt

* In den Testdaten ist jetzt ein Feld `key` enthalten.
* Das Feld ist als `enum` definiert, damit beim Generieren der Daten
  wiederkehrende Schlüssel erzeugt werden.
* Der Datagen-Connector liest das Feld aus den erzeugten Daten aus und
  verwendet es als Schlüssel für die Nachricht.
* _Außerdem:_ Verständlicheres Naming der Beispiel-Felder.

diff --git a/datagen-source-connector.json b/datagen-source-connector.json
index 678a8cf..f28c1a3 100644 (file)
--- a/datagen-source-connector.json
+++ b/datagen-source-connector.json
@@ -7,6 +7,7 @@
     "value.converter": "io.confluent.connect.json.JsonSchemaConverter",
     "value.converter.schemas.enable": "true",
     "value.converter.schema.registry.url": "http://schema-registry:8085",
-    "schema.string": "{\"type\":\"record\",\"name\":\"myrecord\",\"fields\":[{\"name\":\"f1\",\"type\":\"string\"}]}"
+    "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\"}]}",
+    "schema.keyfield": "key"
   }
 }