kafka连接器不导入或导出

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

我试着按照ApacheKafka主页上的教程来做(http://kafka.apache.org/quickstart#quickstart_kafkaconnec)但是当我使用kafka connect进行导入和导出时,我创建了一个文件:

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

我运行命令初始化连接器:

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

但什么都没发生。未发送邮件。甚至“test.sink.txt”文件也没有出现。
我检查文件:连接文件源和连接文件接收器,这些看起来不错:

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

以及:

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

当我跑步时:

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

要查看消息,不显示任何内容,只显示以下内容:

  1. jonathangomez$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic connect-test --from-beginning
  2. [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)

但主题“连接测试”在主题列表中显示为:

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

结果如下:

  1. jonathangomez$ bin/kafka-topics.sh --list --zookeeper localhost:2181
  2. __consumer_offsets
  3. connect-test
  4. my-replicated-topic
  5. pageviews
  6. test
  7. users

我在macossierra10.12.6和apachekafka2.11-2.0.0上运行这个命令。

暂无答案!

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

相关问题