apache-kafka-streams

Ich habe einen grundlegenden Kafka-Streaming-Code, der Datensätze von einem Thema liest, etwas verarbeitet und Datensätze zu einem anderen Thema ausgibt. Wie geht Kafka Streaming mit Nebenläufigkeit um? Läuft alles in einem einzigen Thread? I...

Ist in Kafka Streams eine Funktion integriert, die es ermöglicht, einen einzelnen Eingabestream dynamisch in mehrere Ausgabeströme zu integrieren? KStream.branch erlaubt Verzweigungen basierend auf echten / falschen Prädikaten, aber das ist...

In Samza und Kafka Streams wird die Datenstromverarbeitung in einer Sequenz / Grafik (in Samza "Datenflussgraph" und in Kafka Streams "Topologie" genannt) von Verarbeitungsschritten (in Samza "und" Prozessor "genannt) ausgeführt. in Kafka-Bächen...