Я пытаюсь установить kafka-avro ^1.2.0 в Дженкинс. Этот пакет является оберткой вокруг node-rdkafka...

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

Я хочу написать небольшое приложение Kafka Streams, которое сокращает временные окна входного...

Шаблон исходящих сообщений требует, чтобы в таблице исходящих хранилищ содержался полезный груз...

Я читаю данные из Кафки в Spark Structured Streaming 2.3.0.Данные содержат информацию о некоторых...

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

Мне нужно использовать функцию из библиотеки kafka stream 2.2, однако моя базовая версия брокера...

Мое приложение использует и обрабатывает сообщения Kafka, используя Spark Streaming, используя...

Я заметил, что мое приложение Kafka Streams перейдет в состояние ERROR после невозможности...

Как читать из нескольких тем, используя spark readStream() с разными схемами, и writeStream() в...

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

Я использую материализованную KTable для использования в левом соединении с моим KStream (в то...

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

Обычный способ реализации шаблона исходящих сообщений состоит в том, чтобы сохранить полезную...

У меня есть два потока: [тема A] -> обработка A -> [тема B] -> обработка B -> [тема C] Со входом в...

У меня есть приложение Spark Structured Streaming, которое принимает сообщения из нескольких тем...

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

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

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

Если я объявлю две топологии, в которых узел-приемник Application1 является узлом-источником...

Я создаю KStream с одним потоком, и я получаю эту ошибку Could not create topic:...

Необходимо проверить, являются ли сообщения о событиях, отправленные на Kafka, действительными,...

Среда: Spark 2.3.0, Scala 2.11.12, Kafka (Какая бы ни была последняя версия) У меня есть безопасная...

Если в теме kakfa имеется более одного раздела, в java эти экземпляры / потоки потребителя будут...

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