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

Я пытаюсь прочитать записи из темы Kafka, используя приведенный ниже фрагмент кода: ds_raw = (spark...

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

Я учу Кафку в Скале. Прикрепленный код является просто реализацией подсчета слов с использованием...

У меня есть spark 1.6.3, Scala 2.10.5 и Kafka 1.0.0, возможно ли использовать Kafka 1.0.0 с Scala 2

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

У меня есть Song.Class (song_id, song_name, song_duration). .... package org.example.demo.model;...

Я хотел бы применить OneHotEncoder к нескольким столбцам в моем потоковом фрейме данных, но я...

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

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

Я использую spark-sql 2.4.1, spark-cassandra-connector_2.11-2.4.1.jar и java8. При вставке данных...

Я пытаюсь спроектировать поток Akka, используя Alpakka, чтобы читать события из темы kafka и...

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

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

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

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

Я создал приложение потока kafka, но после его запуска kafka продолжает балансировать с этим...

Вот простое окно сеанса с использованием потоков Кафки: stream .groupBy()

Я хочу прочитать текстовый файл из hdf, используя spark rdd, и записать в kafka по foreach.Code...

мой вопрос о потоках Kafka Ktable.groupBy.aggregate. и результирующие агрегированные значения....

У меня есть приложение kafka streams, использующее тему kafka. Он только потребляет и обрабатывает...

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

Это продолжение этого вопроса . Могу ли я использовать «простой» Apache Kafka Binder вместе с...

Я новичок в Apache Beam. Я пытаюсь прочитать данные из Кафки, используя KafKaIO согласно...

Я застрял в потоках kafka и не могу справиться со сценарием с DSL. Может кто-нибудь, пожалуйста,...