У меня есть потоковое приложение Kafka, которое подписывается на множество тем, и каждая тема имеет...
Мы используем KAfka Broker 2.10 и Kafka java driver 2.0.1 и Kafka Stream Driver 2.0.1. Мы...
У меня есть приложение для потоковой передачи kafka, которое отображает / преобразует сообщение...
Учитывая недавно запущенное приложение Kafka Streams, как можно надежно определить, что оно...
У меня есть сценарий использования, где мой KTable выглядит следующим образом. KTable : orderTable...
Есть ли способ передать или получить доступ к ключу сообщения из раздела join в соединении Kafka...
Я создаю продукт, используя потоки kafka и Kafka с Java / Python. Продукт предназначен для...
У нас была уплотненная тема с одним разделом, и мы добавили в нее один новый раздел. Мы не...
В настоящее время я использую функцию подавления потокового DSL Kafka для дневного окна.у нас может...
У меня возникли проблемы с созданием SerDes для использования с данными, которые я собираю, и мне...
Есть ли способ подсчитать, сколько кучи (или любой другой) памяти приблизительно будет...
У меня есть требование сделать размер пакета опроса равным 500 и выполнить пакетную фиксацию после...
Мне трудно понять пример основного потока kafka: https://github
При использовании StreamDSL я могу вызвать .print(Printed.toConsole()), чтобы увидеть вывод в...
У меня есть следующий сценарий: Таблица A и таблица B объединены с помощью FK. Транзакционная...
Документация Kafka Streams 2.2.0 для метода WindowStore и ReadOnlyWindowStore fetch(K key, Instant...
У меня есть архитектура, в которой у нас есть два отдельных приложения. Первоначальный источник -...
Я новичок в Кафке и стрим.Я создаю локальный магазин для хранения всех обновлений из определенной...
Я получаю Ошибка смещения фиксации в разделе app-KSTREAM-MAP-0000000017-repartition-2 со смещением...
Ссылаясь на это решение , файл My spring-cloud-stream application.yml имеет следующую конфигурацию:...
У меня есть топология, где у меня есть поток A. Из этого потока A я создаю WindowedStore S. A...
Я пытался просмотреть различные учебные пособия, но не совсем ясно по двум аспектам потоков Кафки....
У меня есть записи, которые обрабатываются с помощью Kafka Streams (с помощью Processor API)
Когда я имитирую случай подсчета слов с использованием функции агрегирования, я сталкиваюсь с...
Работа с версией kafka: 2.0.1 & kafka-streams-scala версия 2.0.1 Регистрация сообщений отладки,...