Я загрузил kafka connect с http://docs.confluent.io/2.0.0/quickstart.html#quickstart
Пытаюсь запустить коннектор hdfs. Вот настройки:
connect-standalone.properties:
bootstrap.servers=lvpi00658.s:9092,lvpi00659.s:9092,lvpi00660.s:9092
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
internal.key.converter=org.apache.kafka.connect.storage.StringConverter
internal.value.converter=org.apache.kafka.connect.storage.StringConverter
offset.storage.file.filename=/tmp/connect.offsets
# Flush much faster than normal, which is useful for testing/debugging
offset.flush.interval.ms=10000
key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
а также
quickstart-hdfs.properties:
name=hdfs-sink
connector.class=io.confluent.connect.hdfs.HdfsSinkConnector
tasks.max=1
topics=eightball-stuff11
hdfs.url=hdfs://localhost:9000
flush.size=3
Я запускаю коннектор hdfs следующим образом: cd /home/fclvappi005561/confluent-3.0.0/bin ./connect-standalone ../etc/kafka-connect-hdfs/connect-standalone.properties ../etc/kafka-connect-hdfs/quickstart-hdfs.properties
но я получаю сообщение об ошибке:
Я должен упомянуть, что я запускаю докер-образ hadoop локально по адресу 127.0.0.1:
docker run -d -p 9000:9000 sequenceiq/hadoop-docker:2.7.1
Что это за ошибка отказа в разрешении, которую я вижу? Я нахожусь на другом хосте, чем упомянутые в bootstrap.servers
Ошибка отказа в разрешении находится на стороне hdfs. Пользователь «root» не имеет права записи в каталог hdfs «/ themes».
