From ac0186076fca8d011a7e792f677f366a1d3dbfeb Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sat, 27 Apr 2024 10:33:06 +0200 Subject: [PATCH] Die Testdaten werden mit einem Record-Key erzeugt MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit * 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. --- datagen-source-connector.json | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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" } } -- 2.20.1