Код: Выделить всё
docker run -d -p 2181:2181 -p 3030:3030 -p 8081:8081 -p 8082:8082 -p 8083:8083 -p 9092:9092 --name kafka -e ADV_HOST=127.0.0.1 landoop/fast-data-dev:3.3
kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 3 --topic library
< /code>
Это моя зависимость от помпона: < /p>
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
gatling-test
rate.it
0.0.1-SNAPSHOT
11
UTF-8
3.14.3
4.19.1
3.14.0
3.3.1
3.4.2
3.5
io.gatling.highcharts
gatling-charts-highcharts
${gatling.version}
test
io.github.amerousful
gatling-kafka
${amerousful.version}
maven-compiler-plugin
${maven-compiler-plugin.version}
maven-resources-plugin
${maven-resources-plugin.version}
maven-jar-plugin
${maven-jar-plugin.version}
io.gatling
gatling-maven-plugin
${gatling-maven-plugin.version}
< /code>
Это мой тест на загрузку < /p>
import java.util.Collections;
import io.gatling.javaapi.core.*;
import static io.gatling.javaapi.core.CoreDsl.*;
import io.github.amerousful.kafka.javaapi.KafkaProtocolBuilder;
import static io.github.amerousful.kafka.javaapi.KafkaDsl.*;
public class KafkaLoadTesting extends Simulation {
KafkaProtocolBuilder kafkaProtocol = kafka
.broker(KafkaBroker("localhost", 9092))
.acks("1")
.producerIdenticalSerializer("org.apache.kafka.common.serialization.StringSerializer")
.consumerIdenticalDeserializer("org.apache.kafka.common.serialization.StringDeserializer")
.replyTimeout(10)
.matchByKey();
ScenarioBuilder scn =
scenario("Scenario Kafka")
.exec(
kafka("Kafka: fire and forget")
.send()
.topic("library")
.payload("new message")
);
{
setUp(scn.injectOpen(constantUsersPerSec(100).during(10)).protocols(kafkaProtocol));
}
}
он не удался с журналом:
Код: Выделить всё
20:47:41.892 [main][ERROR][Gatling.scala:86] i.g.a.Gatling$ - Run crashed
java.lang.ClassNotFoundException: com.softwaremill.quicklens.package$PathModify
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:528)
... 19 common frames omitted
Wrapped by: java.lang.NoClassDefFoundError: com/softwaremill/quicklens/package$PathModify
at io.github.amerousful.kafka.protocol.KafkaProtocolBuilder.addProducerProperty(KafkaProtocolBuilder.scala:81)
at io.github.amerousful.kafka.protocol.KafkaProtocolBuilder.brokers(KafkaProtocolBuilder.scala:18)
at io.github.amerousful.kafka.protocol.KafkaProtocolBuilder.broker(KafkaProtocolBuilder.scala:13)
at io.github.amerousful.kafka.javaapi.KafkaProtocolBuilder.broker(KafkaProtocolBuilder.java:27)
at simulations.KafkaLoadTesting.(KafkaLoadTesting.java:13)
at java.base/jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:62)
... 13 common frames omitted
Wrapped by: java.lang.reflect.InvocationTargetException: null
at java.base/jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:74)
at java.base/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:501)
at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:485)
at io.gatling.app.SimulationClass$Java.params(SimulationClass.scala:53)
at io.gatling.app.Runner.load(Runner.scala:72)
at io.gatling.app.Runner.run(Runner.scala:55)
at io.gatling.app.Gatling$.start(Gatling.scala:83)
at io.gatling.app.Gatling$.fromArgs(Gatling.scala:46)
at io.gatling.app.Gatling$.main(Gatling.scala:40)
at io.gatling.app.Gatling.main(Gatling.scala)
at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at io.gatling.plugin.util.ForkMain.runMain(ForkMain.java:67)
at io.gatling.plugin.util.ForkMain.main(ForkMain.java:35)
java.lang.reflect.InvocationTargetException
at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:118)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at io.gatling.plugin.util.ForkMain.runMain(ForkMain.java:67)
at io.gatling.plugin.util.ForkMain.main(ForkMain.java:35)
Caused by: java.lang.reflect.InvocationTargetException
at java.base/jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:74)
at java.base/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:501)
at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:485)
at io.gatling.app.SimulationClass$Java.params(SimulationClass.scala:53)
at io.gatling.app.Runner.load(Runner.scala:72)
at io.gatling.app.Runner.run(Runner.scala:55)
at io.gatling.app.Gatling$.start(Gatling.scala:83)
at io.gatling.app.Gatling$.fromArgs(Gatling.scala:46)
at io.gatling.app.Gatling$.main(Gatling.scala:40)
at io.gatling.app.Gatling.main(Gatling.scala)
at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
... 3 more
Caused by: java.lang.NoClassDefFoundError: com/softwaremill/quicklens/package$PathModify
at io.github.amerousful.kafka.protocol.KafkaProtocolBuilder.addProducerProperty(KafkaProtocolBuilder.scala:81)
at io.github.amerousful.kafka.protocol.KafkaProtocolBuilder.brokers(KafkaProtocolBuilder.scala:18)
at io.github.amerousful.kafka.protocol.KafkaProtocolBuilder.broker(KafkaProtocolBuilder.scala:13)
at io.github.amerousful.kafka.javaapi.KafkaProtocolBuilder.broker(KafkaProtocolBuilder.java:27)
at simulations.KafkaLoadTesting.(KafkaLoadTesting.java:13)
at java.base/jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:62)
... 13 more
Caused by: java.lang.ClassNotFoundException: com.softwaremill.quicklens.package$PathModify
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:528)
Подробнее здесь: https://stackoverflow.com/questions/797 ... fka-plugin
