我试着按照ApacheKafka主页上的教程来做(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”文件也没有出现。
我检查文件:连接文件源和连接文件接收器,这些看起来不错:
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)
但主题“连接测试”在主题列表中显示为:
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
我在macossierra10.12.6和apachekafka2.11-2.0.0上运行这个命令。
暂无答案!
目前还没有任何答案,快来回答吧!