Я создал поток KSQL на основе схемы-реестра, выполнив эту запись .Соединитель JDBC Kafka обновляет...

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

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

Есть ли какой-либо способ (любая статистика JMX или библиотека Java), чтобы понять, когда сегмент...

Я using confluent.connect.cassandra.CassandraSinkConnector, для kafka подключите приемник cassandra

Как я могу выполнить отношение 1 -> N в KSQL У меня есть одна таблица с bob_id в качестве...

У меня 1000 сообщений в моей теме. Мне нужно написать kafka потребителя в scala, чтобы просто...

Мой раздел Кафки получил 20 смещений.У меня есть группа потребителей из 5 подписчиков. Мой вопрос :...

Я новичок в Apache NiFi, но до сих пор весь учебник, который я читаю, говорит об интеграции kafka с...

Итак, у меня есть 2 аналогичных развертывания на k8s, которые извлекают тот же образ из GitLab

Мы бы хотели перечислить все темы Kafka с помощью spring-kafka, чтобы получить результаты,...

У меня есть кластер Kafka, который настроен для использования через ssl через порт 9093. Для того,...

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

Как запустить несколько коннекторов Kafka в мире Kafka Connect в пределах одного распределенного...

Контекст Я кодировал пару небольших Kafka Connect разъемов.Один, который генерирует случайные...

Я пытаюсь перенести тематические данные из одного кластера Kafka в другой (оба на-linux).Для этого...

Я пытаюсь подключиться к производителю Kafka, используя pyspark.Использование производителя консоли...

Я настроил 3 узла кафки кластера.Теперь мы хотим настроить безопасность с Keycloak для kafka

Я использую установку Kafka 2.0.0 с одним узлом, и в течение определенного жизненного цикла в...

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

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

У меня есть тема Кафки с N разделами.Ключ записи - это cookie.Записи распределяются по разделам по...

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

Как указано выше, мы используем Axon (AxonFramework 4.0) с Kafka.У нас есть две службы: ServiceA...

Можно ли написать потребительский cmd / batch-файл kafka для вывода данных в файл каждое окно