2
Wie Strom setzen Auslauf als zuverlässig
Gibt es eine Eigenschaft festlegen
Ist kafkaSpout zuverlässig standardmäßig
Wie die reliablity in kafkaSpout ändernStrom - Zuverlässige Spout
A
Antwort
0
Kafka standardmäßig zuverlässig ist. Hier ist der Code von Partitionmanager-Klasse, die für das Lesen von Nachrichten von Kafka Thema zuständig ist:
collector.emit(tup, new KafkaMessageId(_partition, toEmit.offset()));
Wie Sie der zweite Parameter von emittieren Methode sehen KafkaMessageId ist. In ähnlicher Weise können Sie die Nachrichten-ID in Ihren Tüllen übergeben. Die Nachrichten-ID kann eine gewöhnliche Ganzzahl sein.
Verwandte Themen
- 1. Kafka Storm Integration mit Kafka Spout
- 2. rekursive Strom
- 3. DataColumn.Expression Strom
- 4. Zuverlässige Browsererkennung mit Javascript?
- 5. redis zuverlässige Warteschlange Muster
- 6. Zuverlässige UDP in Java
- 7. Zuverlässige Kubikwurzel in Haskell
- 8. zuverlässige Multicast in C#
- 9. Zuverlässige Auswahlbox funktioniert nicht
- 10. Zuverlässige String-Interpolation in Rails
- 11. Zuverlässige Timer in einer Konsolenanwendung
- 12. Zuverlässige Wiederholung Hintergrundaufgabe auf Android
- 13. Einfache zuverlässige UDP C++ - Bibliotheken
- 14. Effiziente, zuverlässige Anzahl aktiver Objekte
- 15. Hat PyS60 eine zuverlässige Speicherbereinigung?
- 16. Vermeiden NoSuchElementException mit Strom
- 17. Element in Strom einfügen
- 18. Strom von Readlines
- 19. kippte Strom von youtube
- 20. und Strom in Reaktion
- 21. entfernen dynamischen Strom Element
- 22. Strom-Transformation, interne Daten
- 23. Filter Twitter4J Strom
- 24. Strom und lazy evaluation
- 25. Android über Strom api
- 26. 7zipsharp Extraktions/Strom Dekomprimieren
- 27. Java 8 verschachtelter Strom
- 28. Schließen Strom node.js
- 29. Java 8 Strom api Steuerausgang
- 30. Strom Stateful Berechnung: kumulative Summen
Danke, btw, Wie setze ich meinen kafkaSpout als unzuverlässig ... und für den normalen Auslauf auch wie man das so zuverlässig oder unzuverlässig einstellt. – user1942574