From: Kai Moritz <kai@juplo.de>
Date: Sat, 27 Apr 2024 08:33:06 +0000 (+0200)
Subject: Die Testdaten werden mit einem Record-Key erzeugt
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=ac0186076fca8d011a7e792f677f366a1d3dbfeb;p=demos%2Fkafka%2Ftraining

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
--- 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"
   }
 }