Kafka Streams: совместное использование globalStateStore в топологиях

Question

У меня есть загрузочное приложение Spring, которое использует Processor API для создания топологии, а также addGlobalStateStore для той же топологии.

Я хочу создать другую топологию (и, следовательно, еще один KafkaStreams) для чтения из другого набораТемы и хотят поделиться ранее созданным магазином в новой топологии.Под долей я имею в виду, что базовое хранилище состояний должно быть одинаковым для обеих топологий.Любые данные, записанные в одной топологии, должны быть видны в другой.

Возможно ли это без записи конечных точек оболочки для доступа к хранилищу состояний, например, вызовы REST?

Или мой сценарий использования требует внешнего хранилища состояний, например, redis?

Answer 1

Нет, вы не можете совместно использовать государственные магазины по топологиям.Вместо этого, если это возможно, вы можете разбить свои топологии на под-топологии, и это сделает их доступными для всех определенных процессоров.

Если это невозможно для вас, вы можете использовать внешнее хранилище.