branch(new predicate{ business logic if(condition) return true else return false; Когда условие...
Ниже приводится документация Kafka для 2.1. https://kafka.apache.org/documentation/ Offset...
Для входящей записи мне нужно проверить значение и на основе результирующего объекта мне нужно...
У меня возникли проблемы с использованием метода KStream through(), чтобы гарантировать, что...
При выполнении KStream - левое соединение с KTable, я хочу отправить запись обратно в ту же тему,...
Мы используем установку брокера kafka с приложением потоков kafka, которое работает с...
Допустим, я использую API процессора Kafka Streams для написания очень простого процессора, который...
Есть ли способ с постоянным хранилищем состояний разрешить истечение срока действия ключей в...
У нас есть приложение kafka streams (2.0), которое взаимодействует с брокерами kafka (1.1.0)
У меня есть особое требование для вызова интерактивного запроса из потока.Это потому, что мне нужно...
Я создаю запланированный пунктуатор на трансформаторе и планирую его периодическую работу...
В настоящее время я работаю над загрузочным приложением Spring, используя Spring Kafka Consumer API
У меня есть такой случай: пользователи собирают заказы как строки заказа.Я реализовал это с темой...
В следующей статье говорится, что Kafka Streams, если они используют оконные функции,'cksdb...
У меня есть json публикация в одной из моих тем по kafka: { "hash": "ABC",...
Когда закрывается временное окно, конечный результат генерируется немедленно или когда появляется...
Я использую Kafka Streams для потребления данных.В моем местном все в порядке.Я могу потреблять...
В нашем приложении производитель отправляет разные типы данных, и может случиться так, что раздел...
Что означает эта ошибка? Не удалось добавить ошибку в кафке-брокере для потоковых разделов...
Итак, я оцениваю Кафку.В нашем случае использования пришлось бы создавать новые темы, содержащие...
Я искал несколько смежных примеров для потоков Кафки, различные значения для значения конфигурации...
У меня есть потоковое приложение kafka, которое в настоящее время берет 3 темы и объединяет их в...
В настоящее время у нас запущены два экземпляра одного потокового приложения.Метрики сообщаются...
Я использую Kafka и Kafka Streams как часть Spring Cloud Stream.Данные, которые передаются в моем...
Я чувствую, что, возможно, мне не хватает чего-то очень простого, но я все равно спрошу. Существует...