Обмен локальным магазином между разными KafkaStreams

Question

Дано: иметь по два KafkaStreams с топологией DSL каждый. К одной из типологий добавлено локальное хранилище состояний. Каков оптимальный способ для второго KafkaStream обновить локальное хранилище в первом KafkaStreams?

Я мог бы подумать о добавлении процессора в KafkaStreams с локальным хранилищем. Этот процессор имеет (1) некоторый статический список задач, заполненный вторым KafkaStream, (2) Punctuator, который будет обрабатывать задачи из списка задач.

К сожалению, эта конструкция не дает никаких гарантий на отказоустойчивость.

Есть ли лучший подход?

Answer 1

Локальное состояние приложения должно обновляться только самим приложением.

Не уверен, чего именно вы хотите достичь.Одним из способов «обновить» состояние из экземпляра Kafka Streams может быть тема.Экземпляр A создает таблицу из темы.Экземпляр B пишите в эту тему, когда хотите обновить состояние таблицы A.

Надеюсь, это поможет.Если нет, то, возможно, обновите свой вопрос, чтобы дать более подробную информацию о том, чего вы хотите достичь.