Spring Cloud Stream - запрос topi c без явного использования KTable / KStream?

Question

Я использую библиотеку Spring Cloud Stream в приложении Java. Я хочу использовать связыватель Kafka Streams для государственного магазина. Приложение будет отправлять сообщения в topi c, и я sh буду использовать Kafka Streams InteractiveQueryService для извлечения данных из того же topi c. Можно ли выполнять такие запросы как есть, или мне нужно сначала использовать topi c как KTable / KStream и материализовать его, прежде чем я смогу выполнить запросы? У меня нет требования выполнять обработку KTable / KStream для topi c, я просто хочу запросить содержимое topi c. Я надеюсь, что есть какой-то способ материализовать его как хранилище состояний.

Answer 1

Интерактивные запросы - это функция, которая позволяет запрашивать состояния состояний на стороне клиента. Это не функция, которая позволяет запрашивать темы.

Следовательно, если у вас есть данные в топи c, которые вы хотите запросить с помощью «Интерактивных запросов», вам необходимо загрузить данные в состояние магазин в Кафки Потоках.