首页 > 解决方案 > kafka 连接:找不到配置文件

问题描述

我是 kafka 的新手,正在学习使用 kafka connect 从文本(.txt)文件中读取。我创建了 source-config 文件和 worker 配置文件,并将它们保存为资源下的 .properties 文件。

当我从终端运行以下命令时,两个配置文件都出现 NoSuchFileException:
/bin/connect-standalone.sh my-standalone.properties my-file-source.properties

#my-file-source.properties config file
name=local-file-source
connector.class=FileStreamSource
tasks.max=1
file=/tmp/my-test.txt
topic=my-connect-test
# my-standalone.properties worker config file
 
#bootstrap kafka servers
bootstrap.servers=localhost:9092
 
# specify input data format
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
 
# The internal converter used for offsets, most will always want to use the built-in default
internal.key.converter=org.apache.kafka.connect.json.JsonConverter
internal.value.converter=org.apache.kafka.connect.json.JsonConverter
internal.key.converter.schemas.enable=false
internal.value.converter.schemas.enable=false
 
# local file storing offsets and config data
offset.storage.file.filename=/tmp/connect.offsets

将配置文件添加到资源是否正确?我哪里错了?

标签: apache-kafkaapache-kafka-connect

解决方案


推荐阅读