Вот простое определение окна с оператором подавления: stream .groupBy() .windowedBy(SessionWindows

Предположим, у меня есть 2 темы: xyz1, xyz2, каждая из которых имеет 3 раздела. Если у меня есть...

У меня есть требование обрабатывать большие данные, генерируемые Kafka в реальном времени, и...

Недавно я столкнулся с проблемой в потоковом приложении, с которой я ранее не сталкивался, и было...

Я использую потоки Кафки 2.2.1. Я использую функцию подавления для удержания событий до закрытия...

У меня есть приложение Spring Cloud Stream (Kafka Streams версии 2.1) со связывателем Kafka Streams...

У меня есть тема Кафки. У меня есть поток с ключом, являющимся символом акции, и значением,...

У меня есть приложение, которое разветвляется на одну из 20 тем на основе некоторых правил. Это...

Я использую следующую конфигурацию для JSON в своем приложении Kafka Streams, properties

Я работаю над реализацией потокового счетчика Kafka счетчика слов в Scala, в котором я расширил...

Как отправить данные в kstream на конкретный раздел темы? Например, для темы A section2 Я пытался...

Есть ли способ при использовании Kafka обновлять ключ после того, как он не был просмотрен в...

Мое приложение потока kafka не запускается, когда количество потоков в потоке превышает 110....

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

У нас есть одна тема, которая называется igrationstatus , предположим, что мы разбиваем ее так,...

Я хотел бы разделить свой входной поток на два потока, например KStream<String, TypeA> и...

Мы используем API-интерфейсы Kafka streams (0.11.0.1) для получения событий из темы. Но всякий раз,...

Я пытаюсь выполнить локальную агрегацию. В теме ввода есть записи, содержащие несколько элементов,...

Конфигурация задания потока Kafka и Kafka: Нет раздела: 40 Нет задачи потока: 40 Нет потока потока:...

Описание проблемы: Я создаю весеннее облачное приложение Kafka stream. У меня есть одна входная...

Я использую поток Кафки 2.1 Я пытаюсь объединить поток сообщений по их идентификатору. У нас...

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

Я работаю над сценарием использования, где мне нужно запросить KTable (с использованием подхода...

Я разработал приложение для весенней загрузки, используя boot-версию 2.1.3.RELEASE. Добавлены...

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