如何使用Kafka接收器连接器将pdf文件存储在对象存储中？

问题描述

我是Kafka的新手，正在尝试一个用例，其中创建了一个Kafka云对象存储（COS）接收器连接器，并能够通过REST API生成带有文本内容的消息。

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文件（作为二进制XML）

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？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）