Erstellen und Abfragen von Status in Apache Kafka: Kafka Stream?

Question

Ich baue einen Apache-Cluster für meine Bedürfnisse und das meiste davon ist staatenlos. Aber es gibt eine Situation, wegen der ich wirklich Staat brauche.

Um zu erklären, lassen Sie mich sagen, dass ich jeden Apotheke Speicher, der geöffnet wird, und die Transaktionen, die in diesem und jedem Geschäft passieren. So öffnet sich der Laden mit dem Anfangszustand der Anzahl der Medikamente. Da Medikamente verkauft werden und mehr Medikamente vorrätig sind, verändert sich der Staat ständig.

Während Kafka mein Bedürfnis, mit Live-Transaktionen in Echtzeit zu halten, muss ich in der Lage sein, Apotheke Store Zustand und Abfrage und herauszufinden, an einem bestimmten Punkt die Anzahl eines bestimmten Medikaments in einem Geschäft. Ist es möglich? Wird dafür Kafka Stream verwendet?

Answer 1

Ja, Sie können Kafka Streams verwenden, um eine Anwendung zu erstellen, die ein Kafka-Thema konsumiert und einen abfragbaren Speicher verwaltet, der ständig aktualisiert wird, um in Ihrem Beispiel den aktuellen Medikamentenbestand zu verwalten.

Überprüfen Sie die Dokumentation aus, um loszulegen: http://docs.confluent.io/current/streams/index.html

auch diese Beispiele Besuche mit Kafka Streams' "Interactive Queries" Feature:

• https://github.com/confluentinc/examples/blob/3.1.x/kafka-streams/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java
• https://github.com/confluentinc/examples/blob/3.1.x/kafka-streams/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExample.java