注册

DM同步到kafka

Nemesis 2023/07/03 968 3

为提高效率,提问时请提供以下信息,问题描述清晰可优先响应。
【DM版本】:DM8
【操作系统】:银河麒麟v10
【CPU】:鲲鹏920
【问题描述】*:
按以下命令启动目的端kafka的时候,会报错

$JAVA_HOME/bin/java -Djava.ext.dirs="/opt/kafka/kafka_2.13-2.8.1/libs:." com.dameng.dmhs.dmga.service.impl.ExecDMHSKafkaService /opt/dmhs/bin/dmhs_kafka.properties
Exception in thread "main" java.lang.RuntimeException: 初始化DMHS 信息抽取接口失败!errorCode: -1 at com.dameng.dmhs.dmga.service.impl.DMHSNativeCaller.<init>(DMHSNativeCaller.java:35) at com.dameng.dmhs.dmga.service.impl.DMHSKafkaProducer.<init>(DMHSKafkaProducer.java:55) at com.dameng.dmhs.dmga.service.impl.ExecDMHSKafkaService.main(ExecDMHSKafkaService.java:40)

dmhs.hs配置如下,修改过dmhs.hs中的mgr_port和data_prot,启动还是这个错误

<base> <siteid>11</siteid> <mgr_port>25347</mgr_port> <chk_interval>30</chk_interval> <ckpt_interval>60</ckpt_interval> <lang>ch</lang> <version>2.0</version> </base> <exec> <recv> <data_port>25348</data_port> </recv> <name>DM8_TOPIC</name> <enable>1</enable> <char_code>PG_UTF8</char_code> <level>0</level> <exec_thr>16</exec_thr> <exec_sql>1024</exec_sql> <exec_trx>5000</exec_trx> <exec_rows>250</exec_rows> <recv_caches>8</recv_caches> <trxid_tables>1</trxid_tables> <exec_policy>2</exec_policy> <is_kafka>1</is_kafka> <json_format>file</json_format> <max_packet_size>16</max_packet_size> </exec>
回答 0
暂无回答
扫一扫
联系客服