关键字

金仓数据库、KingbaseFlysync ,KFS,同步程序, kafka， message=Error sending message to kafka

问题描述

目标端kafka数据入库过程中，出现报错并停机，且日志中出现了如下提示：
message=Error sending message to kafka

问题分析

这个报错是入库失败的报错，数据无法写入kafka数据库，原因是KFS服务器到kafka服务器网络不稳定导致的入库失败

解决方案

1）在同步程序配置文件flysync.ini中把参数lingerMs设置为0，表示消息立即发送，不批量提交；compressionType设置为lz4，表示将消息压缩为lz4格式，降低网络IO传输开销。

[test@localhost ~]$  vim flysync.ini

在配置文件中kafka目标端服务中添加如下配置并保存

property=replicator.applier.dbms.lingerMs=0
property=replicator.applier.dbms.compressionType=lz4

2）在安装包解析路径下执行./fspm update 参数更新命令

[test@localhost ~]$  cd /home/hes/KingbaseFlySync-V002R002C004BXXXXXXXX-replicator/tools
[test@localhost tools]$ ./fspm update

3）更新成功后，再启动同步程序即可

[test@localhost tools]$  replicator start