Я использую коннектор Confluent Kafka JDBC для получения данных из различных источников.Мне...

Я пытаюсь настроить аутентификацию Zookeeper / Kafka Kerberos, но моя таблица ключей была создана...

Version Info: "org.apache.storm" % "storm-core" % "1.2.1" "org

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

Я запустил локальный kafka, используя следующий docker-compose.yml version: '2' services:...

Ошибка, вызванная соединителем приемника JDBC: org.apache.kafka.connect.errors.DataException:...

Я только начал использовать Kafka и хочу использовать kafka-topics-ui, чтобы просмотреть различные...

Я настроил конвейер данных, используя divolte.io для потоковой передачи данных о кликах с веб-сайта...

Я пытаюсь заставить Кафку работать над docker-compose в первый раз.Приложение работает без докера

я пишу код jave для чтения данных json из локальной файловой системы и хочу отправить эти данные в...

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

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

В основном по умолчанию кластер из 3 брокеров, я получаю спам с этими журналами: Received a...

Как включить метрики jmx для коннекторов Kafka?Я бегу подключен распределен. Я включил метрики jmx...

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

Вот подробный журнал: 配置 文件 [root@mast-1 ~]# grep '^[a-zA-Z]' /opt/kafka/config/server

В моих темах 115 разделов и около 130 потребителей.Я ожидаю, что 115 потребителей в активном...

Возможно ли для потоковой передачи kafka зафиксировать изменения в представлении базы данных?У меня...

Привет Я сталкиваюсь со странной проблемой с увеличением коэффициента репликации Кафки при...

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

Исходя из моего понимания Производитель: При первом вызове локальный кеш реестра схемы пуст. Затем...

Я столкнулся с проблемой конфигурации (я думаю) на некоторых блоках, которые имеют 4 сетевых...

В настоящее время, когда я создаю продюсера для отправки моих записей и, например, по каким-то...

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

В моем приложении я настроил kafka для работы с TLS, поэтому у меня есть несколько потребителей,...