Я использую тему Кафки с startingOffsets, установленным на earliest. Срок хранения кластера...

Я использую KafkaUtils.createDirectStream Kafka API для приема сообщений, а затем обрабатываю...

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

Я использую следующий потребительский код в Spark для чтения из темы Кафки: val df = spark .read

У меня есть эта ошибка в моем коде (wordCount от Kafka), скомпилированном с SBT [error]...

У меня есть Spark Cluster (Автономный кластер, всего 4 рабочих - каждый работник имеет 16 ядер....

У меня есть задание Kafka Streaming Consumer, которое сохраняет данные в таблице Hive. Проблема в...

Попытайтесь понять последовательность в Кафке. Пожалуйста, найдите сценарий и помогите понять....

У меня есть приложение для потокового воспроизведения, которое запускается в конце дня и использует...

У меня есть приложение Kafka Streams, для которого при каждом перезапуске смещения для темы,...

У нас есть потоковое приложение, которое использует семантику "точно один раз", когда один...

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

Я пишу приложение Spring Boot с помощью Spring Kafka. Поскольку мое приложение ориентировано на...

Мы запускаем весеннее облачное приложение, использующее spring-cloud-kafka-streams. Приложение...

Я экспериментирую с режимом непрерывной обработки Spark в структурированном потоке и читаю тему...

У меня есть случай, когда мне нужно прочитать данные из темы, а затем пакетные данные (100 записей)...

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

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

У меня есть тема, которая читается как GlobalKTable и материализована в магазине. Проблема в том,...

Я пытаюсь запустить очень простой поток, используя ProcessorAPI в Scala. class KafkaProcessor...

Я создал SparkConsumer, чтобы я мог отправить файл CSV в Kafka через Spark Structured Streaming. Я...

Я пытаюсь запечь очень простой конвейер, который читает поток событий из Kafka (KafkaIO.read) и...

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

У меня есть простой сценарий для задания ETL: взять данные из темы Кафки и поместить их в таблицу...

У меня есть настройка 3 экземпляров Rest-Proxy (Kafka-rest) в Kubernetes. https://docs.confluent