我是新来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
向资源中添加配置文件的方法正确吗?我哪里出错了?
暂无答案!
目前还没有任何答案,快来回答吧!