Как создать GlobalKTable в процессоре API?

Question

Есть ли GlobalKTable (в DSL API) эквивалент в API Kafka Streams Processor, т.е. есть ли способ настроить хранилища состояний таким образом, чтобы их состояние было глобальным, а не закрытым?

Answer 1

Я думаю, Topology # addGlobalStore - это то, что вы ищете.Вот пример использования из KafkaStreamsTest