无法在loadrunner中执行kafka生产者代码

fnvucqvd  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(282)

我正在尝试通过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兼容性。
我已尝试设置环境和系统变量,但错误仍然存在。你能给我指出正确的方向来解决这个错误吗。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题