Я новичок в kstreams и хочу понять некоторые процессы. Функция агрегирования создает тему kafka с...

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

У меня проблемы с обработкой потока из темы в одну и ту же тему (она называется «ресторан»)....

Я пишу это потоковое приложение Kafka, которое принимает показания датчиков, которые регистрируются...

У меня есть входящие данные для автомобилей и я хочу создать новое событие для поездок. У меня есть...

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

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

Я слежу за документацией по потокам Кафки, и меня смущают некоторые концепции, которые я хочу...

У меня есть тема customer_proposal и я создал поток из нее; CREATE STREAM s_customer_proposal (...

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

При развертывании только с измененной версией Kafka-Streams с 1.1.1 на 2.x.x (без изменения...

В нашей библиотеке есть процессоры данных (код Scala), которые используют типичный поток kafka:...

Поскольку мы мигрировали на Kafka-клиент 2.3 (ранее он был 1.1), мы периодически получаем...

Не могли бы вы дать мне совет относительно подхода к следующей проблеме.У меня есть две темы, одна...

Допустим, мы собираем статистику совместимости моделей автомобилей и шин.Входной поток перечисляет...

У меня есть тема Zeromq, которая генерирует сообщения каждую секунду. Пример: {Orderno : 123 ,...

У меня есть приложение kafka, настроенное на использование реестра схемы.V1 приложения была...

В приложении потоков kafka, если метод process () в вашем процессоре генерирует необработанное...

У меня было дневное окно с первоначальным льготным периодом, установленным как O. Получил новое...

Требуемая функциональность: для данного ключа, key123, многочисленные службы работают параллельно и...

Я хочу создать простой поток Кафки, который пытается преобразовывать события, основываясь на...

Я настраиваю новое потоковое приложение Kafka и хочу использовать пользовательское хранилище...

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

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

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