kafka连接器不导入或导出

66bbxpm5  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(228)

我试着按照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上运行这个命令。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题