开发者社区 > 数据库 > 正文

请问数据库中报错信息如下,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 1005 0
1 条回答
写回答
取消 提交回答
  • shake没有配置调整。需要降低消息的大小或者调大kafka参数。此答案整理自钉钉群“shake数据库同步官方群”

    2022-08-01 15:36:36
    赞同 展开评论 打赏

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

相关电子书

更多
DTCC 2022大会集锦《云原生一站式数据库技术与实践》 立即下载
阿里云瑶池数据库精要2022版 立即下载
2022 DTCC-阿里云一站式数据库上云最佳实践 立即下载