kafka connect:未找到配置文件

vuktfyat  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(283)

我是新来Kafka和学习使用Kafka连接读取文本(.txt)文件。我创建了源配置文件和工作配置文件,并将它们保存为参考资料下的.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

向资源中添加配置文件的方法正确吗?我哪里出错了?

暂无答案!

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

相关问题