Строительство и запрос состояния в Apache Kafka: Kafka Stream?

Question

Я создаю кластер apache для своих нужд, и большинство из них без гражданства. Но есть одна ситуация, из-за которой мне действительно нужно состояние.

Чтобы объяснить, скажем, я храню каждый открывшийся аптечный магазин и транзакции, которые происходят в этом и каждом магазине. Таким образом, магазин открывается с начальным состоянием количества лекарств. По мере продажи лекарств и приобретения большего количества лекарств государство постоянно меняется.

В то время как Kafka обслуживает мою потребность идти в ногу с прямыми трансакциями в реальном времени, мне нужно уметь строить состояние аптечного магазина и запрашивать в любой точке подсчета данного лекарства в магазине. Является ли это возможным? Для чего используется Kafka Stream?

Answer 1

Да, вы можете использовать потоки Kafka для создания приложения, которое использует тему Kafka, и поддерживает постоянно обновляемое хранилище, чтобы поддерживать, как в вашем примере, текущий инвентарь.

Заканчивать документация для начала работы: http://docs.confluent.io/current/streams/index.html

Также проверить эти примеры использования Кафка потоков "Интерактивные запросы" особенность:

• 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