Kafka Connector не импортирует и не экспортирует - PullRequest
Новая
       10

Kafka Connector не импортирует и не экспортирует

0 голосов
/ 03 октября 2018

Я пытаюсь следовать руководству на главной странице Apache Kafka (http://kafka.apache.org/quickstart#quickstart_kafkaconnec), но когда я перехожу к части импорта и экспорта с помощью Kafka Connect, я создаю файл: 

echo -e "foo\nbar" > test.txt

и я запускаю команду для инициализации коннекторов: 

bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties

Но ничего не произошло. Сообщение не отправлено. Даже файл "test.sink.txt" не появляется.

Я проверяю файлы: connect-file-source и connect-file-sink, и они выглядят хорошо: 

name=local-file-source
connector.class=FileStreamSource
tasks.max=1
file=test.txt
topic=connect-test

И: 

name=local-file-sink
connector.class=FileStreamSink
tasks.max=1
file=test.sink.txt
topics=connect-test

Когда я запускаю: 

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic connect-test --from-beginning

Чтобы увидеть сообщения, ничего не отображается только это: 

jonathangomez$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic connect-test --from-beginning
[2018-10-03 01:19:42,901] WARN [Consumer clientId=consumer-1, groupId=console-consumer-30141] 1 partitions have leader brokers without a matching listener, including [connect-test-0] (org.apache.kafka.clients.NetworkClient)

Но тема "connect-test" появляется в списке тем с: 

bin/kafka-topics.sh --list --zookeeper localhost:2181

Результат выглядит следующим образом: 

jonathangomez$ bin/kafka-topics.sh --list --zookeeper localhost:2181    
__consumer_offsets
connect-test
my-replicated-topic
pageviews
test
users

Я запускаю эти команды на macOS Sierra 10.12.6 и Apache Kafka 2.11-2.0.0.

...