我对Kafka的世界还很陌生,正在尝试一个用例,在这个用例中,我创建了一个Kafka云对象存储(cos)接收器连接器,并且能够通过restapi生成一条包含文本内容的消息。
curl -v -X POST -H "Content-Type: text/plain" -H "Accept: application/json" -H "X-Auth-Token:<API_KEY>" -d 'Cool' "KAFKA_URL/topics/cos-sink-connect/records"
这工作,我能够看到一个文本文件 Cool
在对象存储中。
我还可以储存 .svg
使用以下命令
curl --location --request POST 'KAFKA_URL/topics/cos-sink-connect/records' \
--header 'X-Auth-Token: API_KEY' \
--header 'Content-Type: application/octet-stream' \
--data-binary '@/Users/VMac/Downloads/App_Icon_Bright-2.svg'
但是,当我试图发布 .pdf
文件(64 kb)。我看到一个错误
{"error":{"message":"Error reading body: http: request body too large","error_code":400}}
有没有一种方法可以用 .pdf
文件或任何其他文件,并通过接收器连接器将其存储到cos?
暂无答案!
目前还没有任何答案,快来回答吧!