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

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

У меня есть приложение Spring Boot, которое реализует REST API.Когда полезная нагрузка доставляется...

Я использую пакет ниже rapide/laravel-queue-kafka, но выдает ошибку ниже:...

У меня есть проект, настроенный с использованием Spring Boot, где я использую Spring Kafka для...

В моем приложении Java у меня есть процессор Kafka. Мой метод процесса выглядит так: @Override...

Какой метод тома рекомендуется использовать для zookeeper & broker для Apache Kafka, работающего в...

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

Я использую Spring Cloud Stream kafka для обмена сообщениями.Когда я помещаю потребителя и...

У меня есть пункт, который читает из KafkaIO. Direct Runner используется: PipelineOptions options =...

У меня есть работающее приложение Kafka Streams, которое в настоящее время создает два KStreams из...

Пример, который я пытаюсь выяснить, следующий: У нас есть три типа событий. School_Created -...

У меня есть приложение Kafka Streams (Kafka Streams 2.1 + Kafka broker 2.0), которое выполняет...

У меня есть требование присоединиться к 3 темам Кафки. Первые две темы A и B будут добавлены с...

Я пытаюсь настроить KafkaSpout через YAML и получаю следующее сообщение об ошибке Исключение в...

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

Я использую независимый ksql-server в 3-узлах, разговаривая с Kafka кластером из 3-х узлов. Создан...

Является ли confluent kafka API для потоковой передачи, группировки и агрегирования на языке Python

Я изучаю kafka и только что скачал kafka 0.10.1 (так как это требование моего проекта) и всякий раз...

У нас есть Поток, который непрерывно читает потоковые сообщения из раздела Kafka и записывает их в...

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

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

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

Я пытаюсь использовать Kafka для архитектуры pub / sub в проекте .NET Core. Но клиент Confluent...

Я использую Confluent 5.0 на сервере Linux, используя Winscp и Putty. У меня есть приложение Kafka...