Я столкнулся с проблемой с TopologyTestDriver, так как необходимо установить свойство:...

У меня есть вопрос о TopologyTestDriver и KTable;У меня есть потоковая топология, которая...

В Кафке Потоки 2.0. Мой вариант использования: возможность (частичной) повторной обработки данных с...

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

Если у меня есть записи ниже {"A",7} {"B",10} {"C",10} Тогда...

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

У нас есть случай использования, когда у нас есть устаревшая система, данные которой находятся в MS...

Как вы узнаете, когда нужно разделить приложение Kafka Streams на несколько приложений? Например, я...

Я новичок в потоках Kafka, и я попытался перебрать элементы в таблице Streams kafka через...

Фон Несколько машин генерируют события.Эти события отправляются в наш кластер Kafka, где каждая...

На моем локальном ПК я запускаю сервер confluent-oss-5.0.0-2.11 kafka со свойствами сервера по...

Всякий раз, когда я пытаюсь вызвать потребителя для своей группы потребителей, Кафка тратит много...

Может кто-нибудь привести пример использования метрики Spring Cloud Kafka Streams spring.cloud

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

Я запустил коннектор kafka, используя следующую команду: ./bin/connect-standalone...

Я хотел бы полностью понять правила, которым должны следовать процессоры kafka-streams в отношении...

Я хочу суммировать данные одного столбца на основе указанного ключа.Поток похож на id (String) Ключ...

Я занимаюсь разработкой приложения kafka-streams, но у меня возникают проблемы с переопределением...

Я пытаюсь принять jsonSerde в качестве входных данных от тем и должен обработать запись и должен...

У меня есть потоковое приложение kafka, которое использует KTable.Мое приложение работало некоторое...

Почему в глобальной таблице не должно быть включено ведение журнала в kafka? код: if...

У меня запущен экземпляр Kafka (локально, в Docker), и я создал продюсер в Go, используя пакет...

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

KStream<Integer, Integer> stream; KGroupedStream<Integer, Integer> grouped = stream

Я новичок в Apache Kafka.Я прочитал код приложения Steam и наткнулся на операцию агрегации.Я...