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

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

Я пытаюсь создать функцию UDF, которая принимает STRUCT в качестве параметра и возвращает структуру...

Это код для создания единственного сообщения для Кафки, указанный в документе https://doc.akka

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

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

Я пытаюсь использовать сообщения от kafka с помощью alpakka. Я не получаю никакой ошибки от актеров...

У нас есть приложение Spark Streaming (Kafka), которое также выступает в роли продюсера, создавая...

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

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

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

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

Я хочу прочитать только 5000 записей в пакете через приемник jdbc, для которого я использовал batch

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

В основном я выполняю структурированное потоковое задание 24 x 7, записывая в S3. Но натолкнулся на...

Для данного сценария я хочу отфильтровать наборы данных в структурированной потоковой передаче в...

TL; DR: Какое на данный момент лучшее решение для гарантии порядка событий во времени во Flink? Я...

У меня есть тема с сообщениями, сериализованными в protobuf. У меня есть .proto файл с контрактом,...

Я новичок в весеннем облачном потоке и кафке в целом. Каков наилучший подход, чтобы не дать...

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

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

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

Я не могу подключиться к kafka_2.12-2.3.0 из структурированной потоковой передачи spark_2.4.4,...

Я использую имя: kafka_2.12 версия: 2.3.0 . Исходя из трафика / нагрузки, я хочу изменить...

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