Kafka-Streams mit Spring Boot
Hey Leute, ich möchte die Arbeit mit Kafka-Streams Echtzeit-Verarbeitung in meine spring-boot-Projekt. Also ich brauche Kafka-Streams-Konfiguration oder möchte ich KStreams oder KTable, aber ich konnte nicht finden, etwa im internet.
Habe ich Erzeuger und Verbraucher jetzt will ich stream in Echtzeit.
Du musst angemeldet sein, um einen Kommentar abzugeben.
Lassen Sie mich beginnen, indem Sie sagen, dass wenn Sie ein neues Kafka-streams hinzufügen spring-boot oben drauf ist das hinzufügen einer anderen Ebene der Komplexität, und Kafka-streams hat eine große Lernkurve, wie Sie ist. Hier sind die Grundlagen, um Sie gehen:
pom:
Nun das configuration-Objekt. Der folgenden code wird davon ausgegangen, das Sie erstellen zwei-stream-apps, und im Kopf behalten, dass jede Anwendung stellt seine eigenen Verarbeitung Topologie:
Nun kommt der lustige Teil, mit dem die streamsBuilder für die Erstellung Ihrer app (app1 in diesem Beispiel).
Hoffe, das hilft.
können Sie erstellen, die neue spring-boot-Projekt von Grund auf neu mit
https://start.spring.io/
wählen Sie die erforderlichen Versionen/Abhängigkeiten entsprechend an und generieren/herunterladen des Projekts.
können Sie beginnen, die Umsetzung der kstream api-Methoden
(https://kafka.apache.org/10/javadoc/org/apache/kafka/streams/kstream/KStream.html)
Andere Weise zu initialisieren Kafka-Streams-Anwendung im Frühjahr Starten kann werden gefunden auf
https://gist.github.com/itzg/e3ebfd7aec220bf0522e23a65b1296c8
Dieser Ansatz verwendet KafkaStreams bean aufrufen kafkaStreams.start(), die eingespeist werden kann, entweder Topologie oder StreamBuilder Bean.