Kafka FileStreamSinkConnector在被我删除后重新创建了要写入的文件

Question

好吧，这是一个不寻常的问题。

我做了一个文件流接收器连接器如下：

curl -X POST http://cpnode.local.lan:8083/connectors -H "Content-Type: application/json" --data '{
"name":"file-sink-connector-002",
"config": {
"tasks.max":"1",
"batch.size":"1000",
"batch.max.rows":"1000",
"poll.interval.ms":"500",
"connector.class":"org.apache.kafka.connect.file.FileStreamSinkConnector",
"file":"/kafka/names.txt",    
"table.name.format":"tb_sensordata",
"topics":"names",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"key.converter.schemas.enable":"false",
"value.converter": "org.apache.kafka.connect.storage.StringConverter",
"key.converter.schemas.enable":"false"
}
}'

连接器运行时，我删除了names.txt文件

大约一个小时后……它重新创建了文件。。。。。

我启动了控制台生成器，并在主题中生成了一些数据。接收器连接器将数据写入文件中。

有人能解释这种行为吗。。。。plz.

Answer 1

根据这个拉取请求(MINOR：在FileStreamSinkTask#5406中附加或创建文件(，如果FileStreamSink连接器中提到的文件不存在，它将由kafka connect创建。