注册

dmagent调用外部Java函数时报错:达梦的类加载器找不到类

Miner 2025/05/21 213 2

为提高效率,提问时请提供以下信息,问题描述清晰可优先响应。
【DM版本】: DM Database Server 64 V8 (Version: 0x7000c)
【操作系统】:CentOS 7.2
【CPU】:x86_64
【问题描述】*:配置dmagent访问Java函数报异常
提示达梦的类加载器找不到类。但这个jar包是个Fat jar,实际上所有需要的类都已打包了。

代码如下:
Properties props = new Properties();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");

props.put(ProducerConfig.ACKS_CONFIG, "1");
props.put(ProducerConfig.RETRIES_CONFIG, 3);
props.put(ProducerConfig.RETRY_BACKOFF_MS_CONFIG, 1000);

// 创建 KafkaProducer 实例
KafkaProducer<String, String> producer = new KafkaProducer<>(props); /* 这里报错了 */

调用栈如下:
com.dameng.common.util.ReflectUtil$ReflectException: org.apache.kafka.common.config.ConfigException: Invalid value org.apache.kafka.common.serialization.StringSerializer for configuration key.serializer: Class org.apache.kafka.common.serialization.StringSerializer could not be found.
at com.dameng.common.util.ReflectUtil.executeMethod(ReflectUtil.java:424) ~[agent-6.4.0.jar:?]
at com.dameng.agent.plugin.ap.command.JEXE$Processor.process(JEXE.java:231) ~[agent-6.4.0.jar:?]
at com.dameng.agent.plugin.ap.handler.RequestHandler.doHandler(RequestHandler.java:109) ~[agent-6.4.0.jar:?]
at com.dameng.agent.plugin.ap.handler.Handler.run(Handler.java:51) ~[agent-6.4.0.jar:?]
Caused by: org.apache.kafka.common.config.ConfigException: Invalid value org.apache.kafka.common.serialization.StringSerializer for configuration key.serializer: Class org.apache.kafka.common.serialization.StringSerializer could not be found.
at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:728) ~[?:?]
at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:474) ~[?:?]
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:467) ~[?:?]
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:108) ~[?:?]
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:129) ~[?:?]
at org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:409) ~[?:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:326) ~[?:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:298) ~[?:?]
at com.qq.external.ExtFunc.foo(ExtFunc.java:52) ~[?:?]

回答 0
暂无回答
扫一扫
联系客服