confluent

0зной

1ответ

Кафка подключить учебник перестал работать

Я был следующий шаг # 7 (Используйте Кафка Connect для импорта/экспорта данных) по этой ссылке: http://kafka.apache.org/documentation.html#quickstart Он работал хорошо, пока я не удалил «test.txt» фай

3зной

1ответ

Kafka Connect HDFS Sink Issue

Я пытаюсь передать данные с помощью Kafka-Connect с разъемом для подключения HDFS. Как автономные, так и распределенные режимы работают нормально, но запись в HDFS только один раз (на основе размера ф

2зной

3ответ

Запуск системы регистрации конфлюэнтов в окнах

У меня есть среда для окон и мой собственный набор кафки и зоопарка. Чтобы использовать пользовательские объекты, я начал использовать Avro. Но мне нужно было запустить реестр. Скачивал платформу Conf

1зной

2ответ

Конфликтный режим регистрации реестра кластера

Я использую Kafka Connect из Confluent, чтобы потреблять поток Kafka и записывать в HDFS в паркетном формате. Я использую службу реестра Schema в 1 узле, и она работает нормально. Теперь я хочу распро

5зной

1ответ

Kafka Streams с данными поиска на HDFS

Я пишу приложение с потоками Kafka (v0.10.0.1) и хотел бы обогатить записи, которые обрабатываю с помощью данных поиска. Эти данные (timestamped file) записываются в каталог HDFS ежедневно (или 2-3 ра

0зной

1ответ

org.apache.spark.SparkException: Не удалось найти смещения лидера для Set ([test-topic, 0])

Я пытаюсь использовать платформу Confluent и делать запросы Kafka высокого уровня в конечную точку REST с помощью this code as пример. Я использую следующие параметры Кафку: val kafkaParams = Map(