У меня есть приложение SpringBoot с двумя потоковыми процессорами, сопоставленными через Spring...
У меня есть приложение Spring Boot, работающее с Kafka Streams. У меня есть KTable с некоторыми...
Я заметил, что записи Кафки имеют поле CRC. Если запись в файле журнала повреждена (например, один...
Я настроил одну тему на Kafka, затем с помощью загрузочного облака Spring, реактивного потока kafka...
Я использую потоки Кафки DSL и карту для преобразования KStream<String, JsonNode> в...
Я использую функцию уменьшения потоков kafka, и она создает некоторую внутреннюю тему журнала...
мы отправляем данные из DB2 (таблица-1) через CDC в темы Kafka (тема-1). нам нужно согласовать...
У нас есть кафка с высокой доступностью. Мы запускаем несколько потоков kafka и запускаем задания...
Я написал потоковое приложение для обсуждения темы на кластере из 5 брокеров с 10 разделами. Я...
У меня есть следующая топология: Создает государственный магазин Фильтрация записей на основе...
В моем приложении есть потоки Кафки и верблюд, и я хочу извлечь из него некоторые метрики и...
Недавно я попытался убедиться, что мое приложение Kafka Streams (версия 2.0.0) все еще будет...
Я использую KStreams, которые имеют схему AVRO и подключены к реестру схемы. Когда я начинаю...
У нас есть несколько устаревших приложений, в основном состоящих из GUI + сервисный уровень + RDMS....
Как KafkaStream потребляет сообщения из темы. Ниже мой код: Properties props = new Properties();...
Источник событий - это поворот на 180 градусов в том, как многие из нас занимаются архитектурой и...
Поскольку я работаю со значениями Json, я не установил значения по умолчанию. Я обрабатываю KStream...
У меня проблема с тем, что я пытаюсь покинуть 2 потока. MergedKey имеет более 100 списки с тем же...
В приложении Spring Boot я пытаюсь настроить Kafka Streams.С простыми темами Kafka все работает...
Я обращаюсь к хранилищу состояний, чтобы запросить его, и мне пришлось обернуть оператор store()...
У меня простой вопрос. Я хочу соединить 2 KStream s на одном ключе с GenericRecord в качестве...
Я хочу создать таблицу KTable со связанным хранилищем состояний, которую можно запрашивать с...
Я использую приложение Kafka Streams с тремя под-топологиями. Этапы деятельности примерно таковы:...
Кафка версия - 1.0.1 Я получаю следующее исключение через случайные интервалы. Попытка увеличить...
открытый процесс KStream (ввод KStream) { нужен Employee is и Object внутри Employer.Как я могу...