У меня есть кластер kafka (3 машины с 1 zookeeper и 1 брокером на каждой машине) Я использую...

Как написать kafka avro сериализатор и десиализатор (т.е. используя io.confluent.kafka.serializers

__ consumer_offsets хранит смещения всех тем kafka, кроме внутренних тем, таких как темы *...

Я создал очень простой поток akka на основе проекта alpakka, но он ничего не читает из kafka, даже...

У нас есть KStream (взятый из темы Кафки), сообщения которого выглядят так: Новые сообщения ........

У нас есть приложение Streaming Stream.Архитектура выглядит следующим образом: Kinesis Spark to...

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

Я попытался настроить 3-х узловый кластер kafka, используя сливные образы докера. https://hub

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

Я пытаюсь проверить, является ли тема, переданная моему методу "start stream", допустимой / уже...

Сейчас я пытаюсь создать функцию службы сообщений с помощью kafka для использования...

Я настраиваю Hyperledger Fabric, с: 1 организацией, 2 заказчиками, 2 пирами, 4 кафками, 3...

Определение в документах: org.apache.spark.streaming.kafka Класс KafkaUtils static...

"представления ведут себя как форма постоянно обновляемого кэша"? Является ли это средним...

Я изучаю потоки кафки и написал простое приложение, фрагмент которого приведен ниже: MainApp:...

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

Кафка внутренне уничтожит все узлы, которые неправильно опрашивают, но мы не хотим, чтобы плохие...

В одном из приложений наш клиент получает несколько событий в файлах, загруженных на FTP-сервер....

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

Я следую примеру агрегата весенней кафки здесь: https://github

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

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

Вот пример KTable, который я построил и который представляет собой простую агрегацию: String name =...

У нас есть потоковое приложение, реализованное с использованием Spark Structured Streaming.который...

Если у меня есть потоковое приложение Kafka, которое не может опубликовать в теме (поскольку тема...