kafka消息发送大小限制 python confluent_kafka客户端
kafka消息发送大小限制 python confluent_kafka客户端。kafka的broker限制调整过后,发送图片base64编码,出现下面的问题。
·
kafka消息发送大小限制 python confluent_kafka客户端
kafka的broker限制调整过后,发送图片base64编码,出现下面的问题
此处有关于kafka配置的参数说明:
librdkafka/CONFIGURATION.md at master · confluentinc/librdkafka · GitHub
图片上传错误,报出:
cimpl.KafkaException: KafkaError{code=MSG_SIZE_TOO_LARGE,val=10,str="Unable to produce message: Broker: Message size too large"}
的错误。
在客户端增加一个配置:
'message.max.bytes': 200000000
p = Producer({'bootstrap.servers': self.kafkaUrl,
'message.max.bytes': 200000000})

GitCode 天启AI是一款由 GitCode 团队打造的智能助手,基于先进的LLM(大语言模型)与多智能体 Agent 技术构建,致力于为用户提供高效、智能、多模态的创作与开发支持。它不仅支持自然语言对话,还具备处理文件、生成 PPT、撰写分析报告、开发 Web 应用等多项能力,真正做到“一句话,让 Al帮你完成复杂任务”。
更多推荐
所有评论(0)