Я реализовал потребитель Kafka в PySpark (Spark 2.2.1) Я использую технологию структурированной...

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

Есть ли способ настроить расписание, при котором данные в KTable должны сохраняться (.to ()) в теме

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

У меня есть вопрос относительно чтения данных с помощью Spark Direct Streaming (Spark 1.6) из Kafka...

Topology streamTopology = new Topology(); streamTopology.addSource("Source1",...

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

Кто-нибудь использовал Confluent Cloud в производственной среде? Каков его статус? Я слышал, что...

Я использую API-интерфейс Kafka Consumer для копирования всех данных из раздела Kafka в таблицу...

В моей компании мы широко используем Kafka, но мы используем реляционную базу данных для хранения...

В Kafka StreamsBuilder подпись только для таблицы: table(java.lang.String topic) https://kafka

Я использую Кафку 1.1.0. Поток kafka последовательно выдает это исключение (хотя и с разными...

Я работаю на processor node в потоках кафки. Для простого кода я написал, как показано ниже, только...

У нас есть поток веб-событий. Событие разделено на (домен, uid). Все описанные здесь события...

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

В моем приложении я получаю Array[String] из потока и передаю его методу (в качестве параметра...

Я хочу отправить 100 messages/second из моего потока в тему кафки. У меня в потоке данных более чем...

Как заставить потоки кафки работать с log4j? Например, выполнение ниже не приводит к выводу в...

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

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

Я пытаюсь сделать левое внешнее соединение между двумя Kafka Stream, используя PySpark и Structured...

[ { "device_nm": "x1", "type": "external",...

Для чтения данных в KStream я использую связку kafka из весеннего облака. При чтении данных из...

Сценарий - у меня есть 1 тема с 2 разделами с разными наборами данных, скажем, A, B. Я знаю, что...

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