Ich bin neu bei Avro und Kafka. Nach meinem Verständnis von Avro würde allen avro-Datensätzen ein Schema beigefügt sein. Der Kafka-Producer konvertiert die Daten in ein Byte-Array und sendet es an kafka consumer. Der Verbraucher gibt die gesendeten Daten zurück. Meine Frage ist, wie ich das Schema von Kafka-Verbraucher abrufen kann, ohne das Konzept der Schemaregistrierung einzubringen. Gibt es eine Möglichkeit, das Schema von kafka consumer zurück zu bekommen, ohne die Schemaregistrierung zu verwenden?Abrufen von Schema aus Kafka-Consumer ohne Verwendung der Schemaregistrierung
1
A
Antwort
1
Nein, Ihre in avro serialisierte kakfa-Nachricht enthält nur eine Schema-ID. Diese ID wird verwendet, um das gute Schema in der Schemaregistrierung abzurufen.
0
Avro Records wird die schemaId zum Zeitpunkt der Avro-Kodierung an sie angehängt haben. Diese Schema-ID ist die Kennung zum Abrufen des Schemas, das zum Codieren verwendet wurde. Zum Zeitpunkt der Decodierung wird dasselbe Schema verwendet. Also im Grunde können Sie die SchemaId aus dem Datensatz abrufen und dann können Sie das entsprechende Schema für diese ID aus der Schemaregistrierung, aber nicht aus dem Datensatz selbst abrufen.
Verwandte Themen
- 1. was bedeutet identityMapCapacity in der Schemaregistrierung?
- 2. Werte aus ResultSet ohne Verwendung der next() -Methode abrufen
- 3. Anwendungspfad ohne Verwendung von httpcontext abrufen. (asp.net)
- 4. KafkaConsumer Klassennutzung?
- 5. Hostname ohne Verwendung von HttpRequest abrufen
- 6. NiFi Flowfile Attribute von KafkaConsumer
- 7. Abfrage mit dynamischem Schema ohne Verwendung von String-Verkettung
- 8. Abrufen von Daten aus Modal ohne Aktualisierung
- 9. Abrufen der Länge eines Vektors ohne Verwendung der length() -Funktion
- 10. Speichern/Abrufen von JPEG aus der Benutzergalerie ohne erneute Komprimierung
- 11. Abrufen von Informationen aus der Datenbank in OpenCart ohne MVC
- 12. Verwendung von Funktionen aus einer Archivdatei ohne Verwendung von CPP
- 13. Rails mounted engine Verwendung DB-Schema aus der Hauptanwendung
- 14. Kafkaconsumer ist nicht sicher für Multithreading-Zugriff
- 15. Abrufen eines Elements aus einer Datentabelle mit einem Schema
- 16. Daten während der Verwendung von MySQL abrufen
- 17. Verwendung von GenericTypeindicator beim Abrufen von Daten aus Firebase Android
- 18. Schema - Funktionsaufruf ohne Namen
- 19. XML-Schema von MS SQL-Datenbank abrufen
- 20. Mongoose schreibgeschützt ohne Schema
- 21. Abrufen von binären Bilddaten aus der CRML
- 22. Abrufen von Nullabfragen nach Verwendung von QueryEntity
- 23. Abrufen von HTML aus MongoDB zur Verwendung in Vorlage
- 24. Nachricht ohne Protokoll aus Gmail-API abrufen
- 25. Simple-Schema: Felder ohne Typen
- 26. Wie kann man ein Schema aus einer Mungo-Sammlung abrufen?
- 27. Positionserkennung ohne Verwendung von CoreLocation
- 28. Auswerten von JSON aus JSON-Schema
- 29. Android - MIME-Typ aus Datei ohne Erweiterung abrufen
- 30. Daten aus mehreren Abfragen ohne foreach abrufen
Ist das in Kafka, nur die Daten kommen im Byte-Array-Format ohne das Schema? Wie kommt es dann zur Deserialisierung ohne das Schema? – Shri