Я пытаюсь обновить KTable частичными данными объекта. Например. Пользовательский объект...

В настоящее время я оцениваю варианты проектирования / реализации архитектурного подхода Event...

Я уже некоторое время пытаюсь заставить Spring Cloud Stream работать с Kafka Streams, мой проект...

В приложении обработки потока, использующем Spring Cloud Stream, я беру входной поток (с целым...

Вот простое окно сеанса с использованием потоков Кафки: stream .groupBy()

Мы используем версию 2.1.3 для потоков потока kafka весеннего облака - <dependency>...

Встроенный брокер Kafka для Spring не работает при обновлении Spring-Kafka 2.2.x, что требуется для...

Я пытаюсь следовать одному из примеров кодов для Kafka Stream, чтобы убедиться, что мой потребитель...

У меня есть приложение KStream, которое работает некоторое время и создает агрегаты, используя...

Я запускаю приложение потоков Kafka с оконной функцией.Но после 24 часов работы использование...

Мне довольно любопытно, почему неключевое соединение работает с GlobalKTtable против KTable-KTable

Я использую встроенный Kafka для junit и хочу установить каталог состояния для встроенного Kafka. Я...

У меня есть поток событий Кафки объектов: KStream<String, VehicleEventTO> stream = builder

Spring cloud Поток Kafka не повторяется после ошибки десериализации даже после определенной...

Когда наше потоковое приложение kafka пытается восстановить состояние из раздела изменений, каталог...

Проблема: мне нужно узнать, как отправлено сообщение за последние, например, 24 часа.У меня есть...

Я следую примеру агрегата весенней кафки здесь: https://github

У меня реализовано 2 хранилища потоков kafka. Они оба являются постоянными хранилищами значений...

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

У меня есть приложение весенних облачных потоков kafka, которое перехватывает входящие данные,...

Сейчас я пытаюсь получить доступ к описателю основных потоков kafka, выполнив - https://cloud

Попытка объединить два потока по полю временной отметки в полезной нагрузке сообщений приводит к...

Мой вопрос очень близок к Печать Kafka Stream Input на консоль? с небольшой разницей: я использую...

Есть ли способ ограничить или определить максимальное использование памяти приложением kafka...

Можно ли использовать одну и ту же привязку для создания сообщений через Kafka Producer и для...