请问数据库中报错信息如下,mongoshake 有什么配置的方式解决这种大消息问题吗?

请问数据库中报错信息如下,有大日志无法写入kafka导致任务阻塞,除了调大kafka 的消息大小上限外,mongoshake 有什么配置的方式解决这种大消息问题吗? [2022/07/31 17:28:44 CST] [EROR] KafkaWriter send [py_zaixian_classroom_topic@10.255.28.134:9092,10.255.28.133:9092,10.255.28.136:9092,10.255.28.135:9092] with type[json] error[kafka server: Message was too large, server rejected it to avoid allocation error.]

展开
收起
哈喽!小陈 2022-08-01 15:18:50 1023 分享
分享
版权
举报
1 条回答
写回答
取消 提交回答
  • shake没有配置调整。需要降低消息的大小或者调大kafka参数。此答案整理自钉钉群“shake数据库同步官方群”

    2022-08-01 15:36:36 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论

数据库领域前沿技术分享与交流

收录在圈子:
+ 订阅
让用户数据永远在线,让数据无缝的自由流动
还有其他疑问?
咨询AI助理