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
2
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.
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