apache-kafka - 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
将配置文件添加到资源是否正确?我哪里错了?
解决方案
推荐阅读
- javascript - Kintone 时间字段的自定义时间增量
- reactjs - 在我的电影搜索器 Web 应用程序中停止无限搜索
- sapui5 - 如何在多个图块(项目)中加载共享的 i18n 文件?
- c# - 使用收割模式c#读取文本文件
- android-studio - 每次我撤消重新格式化代码时,是否有阻止android studio询问?
- python - 通过 lambda 将 map 与 zip 结合起来
- r - train() 中的 ROC 度量,插入符号包
- python - 数组拆分任务:基于值和自定义类型
- jsf - DataExporter 标记 - PrimeFaces - 仅页面 = “false”
- html - 响应悬停代码