0
Ich habe ein einfaches Web, das Aktienkurs Streaming bestimmter Aktien Symbol anzeigen kann. Der Webserver ist nodejs, die Infrastruktur für die Stockverarbeitung ist kafka, funke mit python. Die Strömung istnodejs Webserver und Python-Kommunikation
googlefinnace -> kafka (pythonfile 1) -> Funke (pythonfile2) -> NodeJS -> Web-Browser
Die Erklärung: kafka und Funken Prozess Lager Infos von Finanz google, dann Ergebnis liefern zu NodeJS Webserver. Das Börsensymbol ist jedoch ein Hardcode für "FB". Ich möchte Benutzer gewünschte Stocksymbol im Web eingeben, und Nodejs kann es zurück an Kafka (Pythonfile1) senden. Ich weiß nicht, wie ich es zwischen nodejs und kafka machen soll. Könnte hier jemand wiegen?
Dank
Danke für die Antwort. Mein Punkt ist, wie man eine Benutzereingabe "stocksymbol" von js zurück zum kafka Server übergibt. Nichts steht im Zusammenhang mit Kafka-Broker, Thema. – nathan
Ein Kafka-Server und ein Kafka-Broker sind dasselbe, daher ist Ihre Frage nicht klar. Wenn Sie von Ihrer Webanwendung in nodejs zu einer Kafka-Anwendung (vielleicht in Python geschrieben) veröffentlichen möchten, veröffentlichen Sie einfach eine Schlüssel/Wert-Paar-Nachricht zu einem Kafka-Thema, das Ihre Backend-Python-Anwendung abonniert. Wenn das Symbol in Ihrer bestehenden node.js-App fest auf "FB" codiert ist, dann ändern Sie einfach diesen Teil des Codes, um ein HTML-Formular von der Verwendung zu akzeptieren und verwenden Sie das bereitgestellte Symbol und entweder den Schlüssel oder den Wert Ihrer kafka-Nachricht. Die Nachricht kann eine einfache Zeichenfolge oder JSON sein. –