Мы планируем удалить версии из названий тем kafka.В настоящее время версия схемы соответствующего...

File Beat не может отправлять журналы из определенной папки. Это папка журналов приложения. Что...

Можно ли получить данные от nifi и добавить эти данные к данным, полученным от kafka? Я попытался...

val rdds = kafkaStream.map(r => (r.key, r.value())) rdds.saveAsTextFiles(Param.hdfsHost +...

Я новичок в Кафке с использованием C #. Раньше все работало нормально. но какие изменения я не знаю...

Я пытаюсь сгенерировать тестовые данные из пользовательских схем avro с использованием dockerized...

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

Я использую Kafka для десериализации сообщений Avro.Для этого программа должна извлечь...

Я пытаюсь подключиться к потоковому кластеру Amazon, управляемому Amazon.Я следовал руководству по...

Я пытаюсь заставить SQLServerConnector от Debezium работать в Kafka Connect, и все, кажется,...

Я работаю над облачным решением Azure.Я использую IoT Hub, подключенный к Kafka, для обработки...

Я создал потребительское приложение для темы Kafka, используя библиотеку confluent.kafka и c #. Мне...

(я новичок в kafka) Я пытаюсь выполнить эту простую настройку на ПК, чтобы прочитать события в...

Нет проблем при первой установке cp-helm-chart. кафка, кафка-коннект, схема ... все отлично...

Я использую Spring Cloud Stream вместе с реестром схемы Aiven , который использует реестр схемы...

Я хочу транслировать сообщения журнала моего приложения на kafka с помощью log4j kafka appender....

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

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

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

Существует две распространенные стратегии для поддержания реплики в синхронизации, репликация...

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

В удаленном облачном кластере kafka брокеры kafka будут обновлены до новой версии (5.1), и поэтому...

Я использую библиотеку Apache Twill для запуска контейнеров YARN в моем кластере YARN.Я запускаю...

Все брокеры в кластере могут нормально запускаться и работать, но иногда один из брокеров...

Если тема установлена ​​без compression, и некоторые данные уже существуют в теме. Теперь тема...