我正在尝试通过loadrunner 12.50中使用java vuser协议的java程序向kafka群集发送消息。代码如下所示:
import lrapi.lr;
import java.util.*;
import org.apache.kafka.clients.producer.*;
import org.apache.kafka.clients.producer.internals.*;
import org.apache.kafka.clients.*;
public class Actions
{
public int init() throws Throwable {
return 0;
}
public int action() throws Throwable {
String topicName = "TopicName";
String value = "PTTest1";
Properties props = new Properties();
props.put("bootstrap.servers", "AAA-abcde-001:9092");
props.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
Producer<String, String> producer = new KafkaProducer <String,String>(props);
ProducerRecord<String, String> record = new ProducerRecord<String,String>(topicName,value);
producer.send(record);
producer.close();
return 0;
}//end of action
public int end() throws Throwable {
return 0;
}
}
虽然它在vugen中没有给出任何编译错误,但在运行时失败,错误如下:
错误:位于java.lang.classloader.defineclass1(本机方法)处,位于java.lang.classloader.defineclass(classloader)处。java:800)在java.security.secureclassloader.defineclass(secureclassloader。java:142)在java.net.urlclassloader.defineclass(urlclassloader。java:449)在java.net.urlclassloader.access$100(urlclassloader。java:71)在java.net.urlclassloader$1.run(urlclassloader。java:361)在java.net.urlclassloader$1.run(urlclassloader。java:355)位于java.net.urlclassloader.findclass(urlclassloader)的java.security.accesscontroller.doprivileged(本机方法)。java:354)在java.lang.classloader.loadclass(classloader。java:425)在sun.misc.launcher$appclassloader.loadclass(launcher。java:308)在java.lang.classloader.loadclass(classloader。java:358)在dummyclassloader.loadclass(dummyclassloader。java:15)在java.lang.classloader.loadclass(classloader。java:358)在scriptfactory.getscriptobject(scriptfactory。java:50)错误:无法创建脚本对象。错误:调用扩展java\u int.dll中的中止清理函数时引发异常:系统异常:异常\u访问\u冲突
我使用了kafka-clients-0.9.0.0.jar(kafka-clients-0.10.0.0)。jar),java-util-1.3.1.jar和jre6\lib\rt.jar,并具有jdk 1.6以实现vugen兼容性。
我已尝试设置环境和系统变量,但错误仍然存在。你能给我指出正确的方向来解决这个错误吗。
暂无答案!
目前还没有任何答案,快来回答吧!