独立模式

bq9c1y66 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(394)

我正在独立模式下运行文件连接器。连接正在运行时，我更新了接收器连接属性文件。除非我重新启动connect，如

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

是否可以在运行时更新连接属性而不重新启动连接

apache-kafka apache-kafka-connect confluent-platform

来源：https://stackoverflow.com/questions/62983418/kafka-connectors-standalone-mode

1条答案

按热度按时间

0yg35tkg1#

不，这不可能使用独立模式。这是使用分布式模式的另一个很好的理由，在这种模式下，您可以在工作进程使用rest接口运行时添加、更新和删除配置。创建或更新要使用的连接器 PUT :

curl -i -X PUT -H  "Content-Type:application/json" http://localhost:8083/connectors/source-file-01/config \
    -d '{
    "connector.class": "org.apache.kafka.connect.file.FileStreamSourceConnector",
    "tasks.max": "1",
    "file": "/usr/share/details.txt",
    "topic": "KTest",
    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
    "value.converter": "org.apache.kafka.connect.storage.StringConverter",
    "name": "file_source"
}'

要删除它，您可以使用

curl -i -X DELETE -H  "Content-Type:application/json" http://localhost:8083/connectors/source-file-01

赞(0）回复(0）举报 2021-06-05

我来回答

独立模式

1条答案

相关问题

热门标签

最新问答