0
Ich habe diesen Zweifel von this question.Warum müssen wir den Serializer in Apache Kafka angeben?
Wenn ich Kafka Streams nicht verwende, warum muss ich beim Erstellen von ZkClient den Serializer verwenden?
A
Antwort
0
Kafka verwendet den Tierpfleger zum Speichern von Metadaten (Themen). Für diese Bibliothek wird com.101tec :: zkClient verwendet. Laut Quellcode ZkClient erfordert ZkSerializer das Serialisieren/Deserialisieren von Daten, die vom Tierpfleger gesendet/empfangen werden. Kafka in sich selbst hat eine Implementierung von ZkSerializer: ZKStringSerializer (in zkUtils widerlegt).
Für die übliche Interaktion mit Kafka (produzieren/verbrauchen) müssen Sie jedoch nicht ZkClient erstellen. Es ist nur für "administrative" Arbeit erforderlich.
Verwandte Themen
- 1. Warum müssen wir kafka Daten zu Apache Funken
- 2. Warum müssen wir die init-Methode angeben?
- 3. Warum müssen wir den Datentyp jedes formalen Arguments separat angeben?
- 4. Warum müssen wir useTestNG() für Tests mit Gradle angeben?
- 5. Warum müssen wir die Anzahl der Flash-Wartezyklen angeben?
- 6. Spark + Kafka streaming NoClassDefFoundError kafka/serializer/StringDecoder
- 7. Warum Apache Kafka in Echtzeit-Verarbeitung
- 8. Warum müssen wir vor() warten()?
- 9. Warum müssen wir den übergeordneten Konstruktor explizit in MSIL aufrufen?
- 10. Standard Serializer für kafka 0.8.2.0
- 11. Inject ObjectMapper in Frühling Kafka Serializer/Deserializer
- 12. C#: Warum verwenden Generika nicht den allgemeinsten Typ, den wir verwenden können, wenn wir keinen angeben?
- 13. Warum müssen wir nicht neu für die Erstellung des Err-Objekts in der Hauptmethode angeben?
- 14. Warum müssen wir Platz vor% c setzen?
- 15. Warum müssen wir gespeicherte Prozedur verwenden?
- 16. Apache Kafka Mehrere Verbraucherinstanzen
- 17. Warum müssen wir Lua's collectgarbage() zweimal anrufen?
- 18. Apache Kafka mehrere Gruppen
- 19. Wie konfiguriere ich den konfluenten kafka Rest Serializer?
- 20. Warum müssen wir Objective-C-Objektfeld beibehalten?
- 21. Warum müssen wir <> für eine Vorlagenklasse mit Standardparametern angeben?
- 22. warum müssen wir localrc-datei für openstack
- 23. Beacon: Warum müssen wir Tx power
- 24. Warum/wann müssen wir super.ViewDidLoad aufrufen?
- 25. Spring-do müssen wir die Bean in XML angeben, wenn wir Annotation verwenden
- 26. Warum müssen wir UpdateWindow nach ShowWindow aufrufen?
- 27. Warum müssen wir eval JSON Klammern hinzufügen?
- 28. Warum müssen wir im Frühling Anmerkungen verwenden?
- 29. Nachricht wurde in Apache Kafka
- 30. Apache Kafka-Zookeeper Eigenschaften
Danke für Ihre Antwort. Bitte lesen Sie den oben gewählten Kommentar in dem Link, den ich gepostet habe. Wenn wir beim Erstellen eines Themas keinen Serializer angeben, wird dieser tatsächlich nicht von Kafka erstellt. Was heißt das? Es hat mich verwirrt. –
@ GopsAB Ich werde davon ausgehen, dass es die Art und Weise verbunden ist, wie Ihr Thema Name serialisiert und in Tierpfleger geschrieben wird. Wenn Sie die Themenliste anzeigen, handelt es sich nur um eine Liste aller Knoten in zookee. Während Kafka es als ungültigen Themenname behandeln kann – Natalia