Kafka-spezifisches Avro-Schema und Einschränkungen
Bei der Erstellung eines Kafka-Datensatzes haben Sie die Möglichkeit, ein benutzerspezifisches Avro-Schema einzugeben, das dann beim Lesen/Schreiben im ausgewählten Topic verwendet wird.
Nachstehend finden Sie eine Liste der verschiedenen Aktionen, die Sie in Talend Pipeline Designer durchführen können, sowie deren Auswirkungen auf Lese-/Schreibvorgänge im betreffenden Kafka-Datensatz.
| Aktion mit dem Datensatz | Auswirkungen in der Anwendung |
|---|---|
|
Abrufen eines Samples aus einem neuen Topic (keine Einträge) in einem Kafka-Datensatz ohne Schema |
Das Sample ist leer. |
|
Abrufen eines Samples aus einem neuen Topic (keine Einträge) in einem Kafka-Datensatz mit gültigem Schema |
Das Sample ist leer. |
|
Abrufen eines Samples aus einem bestehenden Topic in einem Kafka-Datensatz ohne Schema |
Das Sample ist leer. |
|
Abrufen eines Samples aus einem bestehenden Topic in einem Kafka-Datensatz mit kompatiblem binären Schema |
Das Sample wird angezeigt. |
|
Abrufen eines Samples aus einem bestehenden Topic in einem Kafka-Datensatz mit nicht-kompatiblem Schema |
Ein Fehler wird angezeigt. |
|
Ausführen einer Pipeline, die ein neues Topic in einen Kafka-Datensatz ohne Schema schreibt |
Die Pipeline wird ohne Fehler ausgeführt, die Einträge werden mit dem Schema der letzten Komponente vor der Kafka-Komponente persistiert. |
|
Ausführen einer Pipeline, die ein neues Topic in einen Kafka-Datensatz mit einem Schema schreibt, das mit den Pipeline-Daten kompatibel ist |
Die Pipeline wird ohne Fehler ausgeführt, die Einträge werden mit dem Schema des Datensatzes persistiert. |
|
Ausführen einer Pipeline, die ein neues Topic in einen Kafka-Datensatz mit einem Schema schreibt, das nicht mit den Pipeline-Daten kompatibel ist |
Die Pipeline-Ausführung scheitert mit einer Ausnahme. |
|
Ausführen einer Pipeline, die ein bestehendes Topic in einem Kafka-Datensatz mit kompatiblem binären Schema liest |
Die Pipeline wird ohne Fehler ausgeführt. |
|
Ausführen einer Pipeline, die ein bestehendes Topic in einem Kafka-Datensatz mit nicht-kompatiblem Schema liest |
Die Pipeline-Ausführung scheitert mit einer Ausnahme. |