У нас есть простая конфигурация logstash: input { kafka { topics => ["filebeat",...

Используя Kafka Streams, мы не смогли определить конфигурацию, необходимую для сжатия сообщений,...

Я пытался развернуть Кафку, используя Графики руля .Поэтому я определил сервис NodePort для...

Я пытаюсь настроить стек ELK с одним из моих фильтров Logstash на моем локальном компьютере. У меня...

Я работаю над потоковым проектом, где у меня есть поток статистики ping kafka, например: 64 bytes...

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

Ниже приведен мой фрагмент запуска PySpark, который довольно надежен (я давно его использую)....

Как я могу получить уведомление, если в какой-то теме частота сообщений выше или ниже обычной?

В нашем приложении мы стремимся брать сообщения JSON из входной темы, объединять их в заданном окне...

Мы используем потоки akka с alpakka kafka для получения сообщений из разных тем, используя подписку...

Я пытаюсь настроить Kafka в кластере Kubernetes, используя helm. Я использовал Confluent helm chart...

Мы отправляем данные таблицы из db2 в iidr-cdc в kafka.У нас проблема с форматом данных в теме...

Я использую Kafka REST API, выданный из curl POST в ksql. Если я не использую LIMIT20, он зависает

Использование KSQL (Confluent: Version: 5.0.1) Я могу нормально отбрасывать таблицу / поток...

У меня есть поток akka, который непрерывно потребляет данные из темы kafka.Я никогда не выключаю...

Я пытаюсь интегрировать Spark с Кафкой.У меня есть потребитель Kafka есть данные JSON.Я хочу...

Я следую инструкциям Databricks по этому адресу, чтобы начать проект с Kafka: Руководство по...

Для реализации платформы потоковой передачи данных в масштабах всего предприятия мы используем...

Я хочу прочитать данные из темы Кафки и создать спарк Tempview для группировки по нескольким...

У меня есть потоковое задание Apache Beam, которое считывает данные из Kafka и пишет в...

Почему в установочных пакетах rpm для Confluent Platform локальная установка создает большинство...

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

( Редактировать : небольшие правки для лучшего отражения намерения, но большие правки из-за...

У меня есть набор json-сообщений от Kafka, каждый из которых описывает пользователя веб-сайта

Я установил систему kafka с производителем и потребителем, передавая в виде сообщений строки файла...