java.lang.IncompatibleClassChangeError: class org.apache.kafka.common.requests.GroupCoordinatorResponse has interface org.apache.kafka.common.requests.AbstractRequestResponse as super class
at java.lang.ClassLoader.defineClass1(Native Method) ~[?:?]
at java.lang.ClassLoader.defineClass(ClassLoader.java:1013) ~[?:?]
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:150) ~[?:?]
at java.net.URLClassLoader.defineClass(URLClassLoader.java:524) ~[?:?]
at java.net.URLClassLoader$1.run(URLClassLoader.java:427) ~[?:?]
at java.net.URLClassLoader$1.run(URLClassLoader.java:421) ~[?:?]
at java.security.AccessController.doPrivileged(AccessController.java:714) ~[?:?]
at java.net.URLClassLoader.findClass(URLClassLoader.java:420) ~[?:?]
at java.lang.ClassLoader.loadClass(ClassLoader.java:588) ~[?:?]
at java.lang.ClassLoader.loadClass(ClassLoader.java:521) ~[?:?]
at java.lang.Class.forName0(Native Method) ~[?:?]
at java.lang.Class.forName(Class.java:496) ~[?:?]
at java.lang.Class.forName(Class.java:475) ~[?:?]
at org.apache.jorphan.reflect.ClassFinder$ExtendsClassFilter.isChildOf(ClassFinder.java:100) ~[jorphan.jar:5.5]
at org.apache.jorphan.reflect.ClassFinder$ExtendsClassFilter.accept(ClassFinder.java:86) ~[jorphan.jar:5.5]
at org.apache.jorphan.reflect.ClassFinder.applyFiltering(ClassFinder.java:404) ~[jorphan.jar:5.5]
at org.apache.jorphan.reflect.ClassFinder.lambda$findClassesInOnePath$2(ClassFinder.java:364) ~[jorphan.jar:5.5]
at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?]
at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?]
at java.util.zip.ZipFile$EntrySpliterator.tryAdvance(ZipFile.java:565) ~[?:?]
at java.util.Spliterator.forEachRemaining(Spliterator.java:332) ~[?:?]
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?]
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?]
at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?]
at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?]
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?]
at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596) ~[?:?]
at org.apache.jorphan.reflect.ClassFinder.findClassesInOnePath(ClassFinder.java:362) ~[jorphan.jar:5.5]
at org.apache.jorphan.reflect.ClassFinder.findClasses(ClassFinder.java:326) ~[jorphan.jar:5.5]
at org.apache.jorphan.reflect.ClassFinder.findClassesThatExtend(ClassFinder.java:299) ~[jorphan.jar:5.5]
at org.apache.jmeter.gui.action.ActionRouter.findClassesThatExtend(ActionRouter.java:314) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.gui.action.ActionRouter.populateCommandMap(ActionRouter.java:350) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.JMeterGuiLauncher$startGuiInternal$2.invokeSuspend(JMeterGuiLauncher.kt:106) ~[ApacheJMeter_core.jar:5.5]
at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33) ~[kotlin-stdlib-1.6.21.jar:1.6.21-release-334(1.6.21)]
at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106) ~[kotlinx-coroutines-core-jvm-1.6.1.jar:?]
at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:570) ~[kotlinx-coroutines-core-jvm-1.6.1.jar:?]
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:749) ~[kotlinx-coroutines-core-jvm-1.6.1.jar:?]
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:677) ~[kotlinx-coroutines-core-jvm-1.6.1.jar:?]
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:664) ~[kotlinx-coroutines-core-jvm-1.6.1.jar:?]
2023-06-08 21:43:24,091 ERROR o.a.j.r.ClassFinder: Error filtering class org.apache.kafka.common.requests.ListOffsetResponse, it will be ignored
java.lang.IncompatibleClassChangeError: class org.apache.kafka.common.requests.ListOffsetResponse has interface org.apache.kafka.common.requests.AbstractRequestResponse as super class
at java.lang.ClassLoader.defineClass1(Native Method) ~[?:?]
at java.lang.ClassLoader.defineClass(ClassLoader.java:1013) ~[?:?]
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:150) ~[?:?]
at java.net.URLClassLoader.defineClass(URLClassLoader.java:524) ~[?:?]
at java.net.URLClassLoader$1.run(URLClassLoader.java:427) ~[?:?]
at java.net.URLClassLoader$1.run(URLClassLoader.java:421) ~[?:?]
at java.security.AccessController.doPrivileged(AccessController.java:714) ~[?:?]
at java.net.URLClassLoader.findClass(URLClassLoader.java:420) ~[?:?]
at java.lang.ClassLoader.loadClass(ClassLoader.java:588) ~[?:?]
at java.lang.ClassLoader.loadClass(ClassLoader.java:521) ~[?:?]
at java.lang.Class.forName0(Native Method) ~[?:?]
at java.lang.Class.forName(Class.java:496) ~[?:?]
at java.lang.Class.forName(Class.java:475) ~[?:?]
at org.apache.jorphan.reflect.ClassFinder$ExtendsClassFilter.isChildOf(ClassFinder.java:100) ~[jorphan.jar:5.5]
at org.apache.jorphan.reflect.ClassFinder$ExtendsClassFilter.accept(ClassFinder.java:86) ~[jorphan.jar:5.5]
at org.apache.jorphan.reflect.ClassFinder.applyFiltering(ClassFinder.java:404) ~[jorphan.jar:5.5]
at org.apache.jorphan.reflect.ClassFinder.lambda$findClassesInOnePath$2(ClassFinder.java:364) ~[jorphan.jar:5.5]
at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?]
at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?]
at java.util.zip.ZipFile$EntrySpliterator.tryAdvance(ZipFile.java:565) ~[?:?]
at java.util.Spliterator.forEachRemaining(Spliterator.java:332) ~[?:?]
java.lang.IncompatibleClassChangeError: class org.apache.kafka.common.requests.ListOffsetResponse has interface org.apache.kafka.common.requests.AbstractRequestResponse as super class
at java.lang.ClassLoader.defineClass1(Native Method) ~[?:?]
at java.lang.ClassLoader.defineClass(ClassLoader.java:1013) ~[?:?]
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:150) ~[?:?]
at java.net.URLClassLoader.defineClass(URLClassLoader.java:524) ~[?:?]
at java.net.URLClassLoader$1.run(URLClassLoader.java:427) ~[?:?]
at java.net.URLClassLoader$1.run(URLClassLoader.java:421) ~[?:?]
at java.security.AccessController.doPrivileged(AccessController.java:714) ~[?:?]
at java.net.URLClassLoader.findClass(URLClassLoader.java:420) ~[?:?]
at java.lang.ClassLoader.loadClass(ClassLoader.java:588) ~[?:?]
2023-06-08 21:51:03,845 INFO o.a.j.e.StandardJMeterEngine: Running the test!
2023-06-08 21:51:03,846 INFO o.a.j.s.SampleEvent: List of sample_variables: []
2023-06-08 21:51:03,846 INFO o.a.j.s.SampleEvent: List of sample_variables: []
2023-06-08 21:51:03,847 INFO o.a.j.e.u.CompoundVariable: Note: Function class names must contain the string: '.functions.'
2023-06-08 21:51:03,847 INFO o.a.j.e.u.CompoundVariable: Note: Function class names must not contain the string: '.gui.'
2023-06-08 21:51:03,892 INFO c.d.j.k.c.KafkaProducerConfig: Setting up Additional properties
2023-06-08 21:51:03,898 INFO o.a.k.c.p.ProducerConfig: ProducerConfig values:
acks = -1
batch.size = 16384
bootstrap.servers = [localhost1:9091, localhost2:9091, broker:9092]
buffer.memory = 33554432
client.dns.lookup = use_all_dns_ips
client.id = JMeter-Producer-1
compression.type = none
connections.max.idle.ms = 540000
delivery.timeout.ms = 120000
enable.idempotence = true
interceptor.classes = []
key.serializer = class org.apache.kafka.common.serialization.StringSerializer
linger.ms = 0
max.block.ms = 60000
max.in.flight.requests.per.connection = 5
max.request.size = 1048576
metadata.max.age.ms = 300000
metadata.max.idle.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partitioner.adaptive.partitioning.enable = true
partitioner.availability.timeout.ms = 0
partitioner.class = null
partitioner.ignore.keys = false
receive.buffer.bytes = 32768
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = [hidden]
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = SCRAM-SHA-256
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = SASL_PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
transaction.timeout.ms = 60000
transactional.id = null
value.serializer = class org.apache.kafka.common.serialization.StringSerializer
2023-06-08 21:51:03,905 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=JMeter-Producer-1] Instantiated an idempotent producer.
2023-06-08 21:51:03,982 WARN o.a.k.c.ClientUtils: Couldn't resolve server localhost1:9091 from bootstrap.servers as DNS resolution failed for localhost1
2023-06-08 21:51:04,071 WARN o.a.k.c.ClientUtils: Couldn't resolve server localhost2:9091 from bootstrap.servers as DNS resolution failed for localhost2
2023-06-08 21:51:04,187 WARN o.a.k.c.ClientUtils: Couldn't resolve server broker:9092 from bootstrap.servers as DNS resolution failed for broker
2023-06-08 21:51:04,188 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=JMeter-Producer-1] Closing the Kafka producer with timeoutMillis = 0 ms.
2023-06-08 21:51:04,189 INFO o.a.k.c.m.Metrics: Metrics scheduler closed
2023-06-08 21:51:04,189 INFO o.a.k.c.m.Metrics: Closing reporter org.apache.kafka.common.metrics.JmxReporter
2023-06-08 21:51:04,189 INFO o.a.k.c.m.Metrics: Metrics reporters closed
2023-06-08 21:51:04,192 INFO o.a.k.c.u.AppInfoParser: App info kafka.producer for JMeter-Producer-1 unregistered
2023-06-08 21:51:04,193 ERROR c.d.j.k.c.KafkaProducerConfig: Error establishing Kafka producer client!
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:471) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:291) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:318) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:303) ~[kafka-clients-3.3.2.jar:?]
at com.di.jmeter.kafka.config.KafkaProducerConfig.testStarted(KafkaProducerConfig.java:81) ~[di-kafkameter-1.2.jar:?]
at org.apache.jmeter.engine.StandardJMeterEngine.notifyTestListenersOfStart(StandardJMeterEngine.java:218) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.engine.StandardJMeterEngine.run(StandardJMeterEngine.java:396) ~[ApacheJMeter_core.jar:5.5]
at java.lang.Thread.run(Thread.java:1623) ~[?:?]
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:89) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:445) ~[kafka-clients-3.3.2.jar:?]
... 7 more
2023-06-08 21:51:04,194 INFO o.a.j.g.u.JMeterMenuBar: setRunning(true, *local*)
2023-06-08 21:51:04,231 INFO o.a.j.e.StandardJMeterEngine: Starting ThreadGroup: 1 : Thread Group
2023-06-08 21:51:04,231 INFO o.a.j.e.StandardJMeterEngine: Starting 1 threads for group Thread Group.
2023-06-08 21:51:04,231 INFO o.a.j.e.StandardJMeterEngine: Thread will continue on error
2023-06-08 21:51:04,231 INFO o.a.j.t.ThreadGroup: Starting thread group... number=1 threads=1 ramp-up=1 delayedStart=false
2023-06-08 21:51:04,233 INFO o.a.j.t.ThreadGroup: Started thread group number 1
2023-06-08 21:51:04,233 INFO o.a.j.e.StandardJMeterEngine: All thread groups have been started
2023-06-08 21:51:04,233 INFO o.a.j.t.JMeterThread: Thread started: Thread Group 1-1
2023-06-08 21:51:04,234 INFO c.d.j.k.s.KafkaProducerSampler: Exception occurred while sending message to kafka
2023-06-08 21:51:04,234 ERROR o.a.j.s.SampleResult: setEndTime must be called after setStartTime
java.lang.Throwable: Invalid call sequence
at org.apache.jmeter.samplers.SampleResult.setEndTime(SampleResult.java:1107) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.samplers.SampleResult.sampleEnd(SampleResult.java:1145) ~[ApacheJMeter_core.jar:5.5]
at com.di.jmeter.kafka.sampler.KafkaProducerSampler.sample(KafkaProducerSampler.java:93) ~[di-kafkameter-1.2.jar:?]
at org.apache.jmeter.threads.JMeterThread.doSampling(JMeterThread.java:651) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.executeSamplePackage(JMeterThread.java:570) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.processSampler(JMeterThread.java:501) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:268) ~[ApacheJMeter_core.jar:5.5]
at java.lang.Thread.run(Thread.java:1623) ~[?:?]
2023-06-08 21:51:04,234 INFO o.a.j.t.JMeterThread: Thread is done: Thread Group 1-1
2023-06-08 21:51:04,234 INFO o.a.j.t.JMeterThread: Thread finished: Thread Group 1-1
2023-06-08 21:51:04,234 INFO o.a.j.e.StandardJMeterEngine: Notifying test listeners of end of test
2023-06-08 21:51:04,235 INFO o.a.j.g.u.JMeterMenuBar: setRunning(false, *local*)
2023-06-08 21:51:37,442 INFO o.a.j.e.StandardJMeterEngine: Running the test!
2023-06-08 21:51:37,443 INFO o.a.j.s.SampleEvent: List of sample_variables: []
2023-06-08 21:51:37,443 INFO c.d.j.k.c.KafkaProducerConfig: Setting up Additional properties
2023-06-08 21:51:37,444 INFO o.a.k.c.p.ProducerConfig: ProducerConfig values:
acks = -1
batch.size = 16384
bootstrap.servers = [broker:9092]
buffer.memory = 33554432
client.dns.lookup = use_all_dns_ips
client.id = JMeter-Producer-1
compression.type = none
connections.max.idle.ms = 540000
delivery.timeout.ms = 120000
enable.idempotence = true
interceptor.classes = []
key.serializer = class org.apache.kafka.common.serialization.StringSerializer
linger.ms = 0
max.block.ms = 60000
max.in.flight.requests.per.connection = 5
max.request.size = 1048576
metadata.max.age.ms = 300000
metadata.max.idle.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partitioner.adaptive.partitioning.enable = true
partitioner.availability.timeout.ms = 0
partitioner.class = null
partitioner.ignore.keys = false
receive.buffer.bytes = 32768
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = [hidden]
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = SCRAM-SHA-256
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = SASL_PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
transaction.timeout.ms = 60000
transactional.id = null
value.serializer = class org.apache.kafka.common.serialization.StringSerializer
2023-06-08 21:51:37,445 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=JMeter-Producer-1] Instantiated an idempotent producer.
2023-06-08 21:51:37,449 WARN o.a.k.c.ClientUtils: Couldn't resolve server broker:9092 from bootstrap.servers as DNS resolution failed for broker
2023-06-08 21:51:37,449 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=JMeter-Producer-1] Closing the Kafka producer with timeoutMillis = 0 ms.
2023-06-08 21:51:37,450 INFO o.a.k.c.m.Metrics: Metrics scheduler closed
2023-06-08 21:51:37,450 INFO o.a.k.c.m.Metrics: Closing reporter org.apache.kafka.common.metrics.JmxReporter
2023-06-08 21:51:37,450 INFO o.a.k.c.m.Metrics: Metrics reporters closed
2023-06-08 21:51:37,450 INFO o.a.k.c.u.AppInfoParser: App info kafka.producer for JMeter-Producer-1 unregistered
2023-06-08 21:51:37,450 ERROR c.d.j.k.c.KafkaProducerConfig: Error establishing Kafka producer client!
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:471) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:291) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:318) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:303) ~[kafka-clients-3.3.2.jar:?]
at com.di.jmeter.kafka.config.KafkaProducerConfig.testStarted(KafkaProducerConfig.java:81) ~[di-kafkameter-1.2.jar:?]
at org.apache.jmeter.engine.StandardJMeterEngine.notifyTestListenersOfStart(StandardJMeterEngine.java:218) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.engine.StandardJMeterEngine.run(StandardJMeterEngine.java:396) ~[ApacheJMeter_core.jar:5.5]
at java.lang.Thread.run(Thread.java:1623) ~[?:?]
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:89) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:445) ~[kafka-clients-3.3.2.jar:?]
... 7 more
2023-06-08 21:51:37,451 INFO o.a.j.g.u.JMeterMenuBar: setRunning(true, *local*)
2023-06-08 21:51:37,490 INFO o.a.j.e.StandardJMeterEngine: Starting ThreadGroup: 1 : Thread Group
2023-06-08 21:51:37,490 INFO o.a.j.e.StandardJMeterEngine: Starting 1 threads for group Thread Group.
2023-06-08 21:51:37,490 INFO o.a.j.e.StandardJMeterEngine: Thread will continue on error
2023-06-08 21:51:37,490 INFO o.a.j.t.ThreadGroup: Starting thread group... number=1 threads=1 ramp-up=1 delayedStart=false
2023-06-08 21:51:37,490 INFO o.a.j.t.ThreadGroup: Started thread group number 1
2023-06-08 21:51:37,490 INFO o.a.j.e.StandardJMeterEngine: All thread groups have been started
2023-06-08 21:51:37,490 INFO o.a.j.t.JMeterThread: Thread started: Thread Group 1-1
2023-06-08 21:51:37,491 INFO c.d.j.k.s.KafkaProducerSampler: Exception occurred while sending message to kafka
2023-06-08 21:51:37,491 ERROR o.a.j.s.SampleResult: setEndTime must be called after setStartTime
java.lang.Throwable: Invalid call sequence
at org.apache.jmeter.samplers.SampleResult.setEndTime(SampleResult.java:1107) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.samplers.SampleResult.sampleEnd(SampleResult.java:1145) ~[ApacheJMeter_core.jar:5.5]
at com.di.jmeter.kafka.sampler.KafkaProducerSampler.sample(KafkaProducerSampler.java:93) ~[di-kafkameter-1.2.jar:?]
at org.apache.jmeter.threads.JMeterThread.doSampling(JMeterThread.java:651) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.executeSamplePackage(JMeterThread.java:570) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.processSampler(JMeterThread.java:501) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:268) ~[ApacheJMeter_core.jar:5.5]
at java.lang.Thread.run(Thread.java:1623) ~[?:?]
2023-06-08 21:51:37,491 INFO o.a.j.t.JMeterThread: Thread is done: Thread Group 1-1
2023-06-08 21:51:37,491 INFO o.a.j.t.JMeterThread: Thread finished: Thread Group 1-1
2023-06-08 21:51:37,491 INFO o.a.j.e.StandardJMeterEngine: Notifying test listeners of end of test
2023-06-08 21:51:37,492 INFO o.a.j.g.u.JMeterMenuBar: setRunning(false, *local*)
2023-06-08 21:52:50,085 INFO o.a.j.e.StandardJMeterEngine: Running the test!
2023-06-08 21:52:50,086 INFO o.a.j.s.SampleEvent: List of sample_variables: []
2023-06-08 21:52:50,086 INFO c.d.j.k.c.KafkaProducerConfig: Setting up Additional properties
2023-06-08 21:52:50,087 INFO o.a.k.c.p.ProducerConfig: ProducerConfig values:
acks = -1
batch.size = 16384
bootstrap.servers = [broker:9092]
buffer.memory = 33554432
client.dns.lookup = use_all_dns_ips
client.id = JMeter-Producer-1
compression.type = none
connections.max.idle.ms = 540000
delivery.timeout.ms = 120000
enable.idempotence = true
interceptor.classes = []
key.serializer = class org.apache.kafka.common.serialization.StringSerializer
linger.ms = 0
max.block.ms = 60000
max.in.flight.requests.per.connection = 5
max.request.size = 1048576
metadata.max.age.ms = 300000
metadata.max.idle.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partitioner.adaptive.partitioning.enable = true
partitioner.availability.timeout.ms = 0
partitioner.class = null
partitioner.ignore.keys = false
receive.buffer.bytes = 32768
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = [hidden]
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = SCRAM-SHA-256
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = SASL_PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
transaction.timeout.ms = 60000
transactional.id = null
value.serializer = class org.apache.kafka.common.serialization.StringSerializer
2023-06-08 21:52:50,087 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=JMeter-Producer-1] Instantiated an idempotent producer.
2023-06-08 21:52:50,142 WARN o.a.k.c.ClientUtils: Couldn't resolve server broker:9092 from bootstrap.servers as DNS resolution failed for broker
2023-06-08 21:52:50,142 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=JMeter-Producer-1] Closing the Kafka producer with timeoutMillis = 0 ms.
2023-06-08 21:52:50,143 INFO o.a.k.c.m.Metrics: Metrics scheduler closed
2023-06-08 21:52:50,143 INFO o.a.k.c.m.Metrics: Closing reporter org.apache.kafka.common.metrics.JmxReporter
2023-06-08 21:52:50,143 INFO o.a.k.c.m.Metrics: Metrics reporters closed
2023-06-08 21:52:50,143 INFO o.a.k.c.u.AppInfoParser: App info kafka.producer for JMeter-Producer-1 unregistered
2023-06-08 21:52:50,143 ERROR c.d.j.k.c.KafkaProducerConfig: Error establishing Kafka producer client!
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:471) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:291) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:318) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:303) ~[kafka-clients-3.3.2.jar:?]
at com.di.jmeter.kafka.config.KafkaProducerConfig.testStarted(KafkaProducerConfig.java:81) ~[di-kafkameter-1.2.jar:?]
at org.apache.jmeter.engine.StandardJMeterEngine.notifyTestListenersOfStart(StandardJMeterEngine.java:218) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.engine.StandardJMeterEngine.run(StandardJMeterEngine.java:396) ~[ApacheJMeter_core.jar:5.5]
at java.lang.Thread.run(Thread.java:1623) ~[?:?]
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:89) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:445) ~[kafka-clients-3.3.2.jar:?]
... 7 more
2023-06-08 21:52:50,143 INFO o.a.j.g.u.JMeterMenuBar: setRunning(true, *local*)
2023-06-08 21:52:50,169 INFO o.a.j.e.StandardJMeterEngine: Starting ThreadGroup: 1 : Thread Group
2023-06-08 21:52:50,169 INFO o.a.j.e.StandardJMeterEngine: Starting 1 threads for group Thread Group.
2023-06-08 21:52:50,169 INFO o.a.j.e.StandardJMeterEngine: Thread will continue on error
2023-06-08 21:52:50,169 INFO o.a.j.t.ThreadGroup: Starting thread group... number=1 threads=1 ramp-up=1 delayedStart=false
2023-06-08 21:52:50,169 INFO o.a.j.t.ThreadGroup: Started thread group number 1
2023-06-08 21:52:50,170 INFO o.a.j.e.StandardJMeterEngine: All thread groups have been started
2023-06-08 21:52:50,170 INFO o.a.j.t.JMeterThread: Thread started: Thread Group 1-1
2023-06-08 21:52:50,170 INFO c.d.j.k.s.KafkaProducerSampler: Exception occurred while sending message to kafka
2023-06-08 21:52:50,170 ERROR o.a.j.s.SampleResult: setEndTime must be called after setStartTime
java.lang.Throwable: Invalid call sequence
at org.apache.jmeter.samplers.SampleResult.setEndTime(SampleResult.java:1107) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.samplers.SampleResult.sampleEnd(SampleResult.java:1145) ~[ApacheJMeter_core.jar:5.5]
at com.di.jmeter.kafka.sampler.KafkaProducerSampler.sample(KafkaProducerSampler.java:93) ~[di-kafkameter-1.2.jar:?]
at org.apache.jmeter.threads.JMeterThread.doSampling(JMeterThread.java:651) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.executeSamplePackage(JMeterThread.java:570) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.processSampler(JMeterThread.java:501) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:268) ~[ApacheJMeter_core.jar:5.5]
at java.lang.Thread.run(Thread.java:1623) ~[?:?]
2023-06-08 21:52:50,170 INFO o.a.j.t.JMeterThread: Thread is done: Thread Group 1-1
2023-06-08 21:52:50,170 INFO o.a.j.t.JMeterThread: Thread finished: Thread Group 1-1
2023-06-08 21:52:50,171 INFO o.a.j.e.StandardJMeterEngine: Notifying test listeners of end of test
2023-06-08 21:52:50,171 INFO o.a.j.g.u.JMeterMenuBar: setRunning(false, *local*)
2023-06-08 21:52:50,451 INFO o.a.j.e.StandardJMeterEngine: Running the test!
2023-06-08 21:52:50,452 INFO o.a.j.s.SampleEvent: List of sample_variables: []
2023-06-08 21:52:50,452 INFO c.d.j.k.c.KafkaProducerConfig: Setting up Additional properties
2023-06-08 21:52:50,453 INFO o.a.k.c.p.ProducerConfig: ProducerConfig values:
acks = -1
batch.size = 16384
bootstrap.servers = [broker:9092]
buffer.memory = 33554432
client.dns.lookup = use_all_dns_ips
client.id = JMeter-Producer-1
compression.type = none
connections.max.idle.ms = 540000
delivery.timeout.ms = 120000
enable.idempotence = true
interceptor.classes = []
key.serializer = class org.apache.kafka.common.serialization.StringSerializer
linger.ms = 0
max.block.ms = 60000
max.in.flight.requests.per.connection = 5
max.request.size = 1048576
metadata.max.age.ms = 300000
metadata.max.idle.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partitioner.adaptive.partitioning.enable = true
partitioner.availability.timeout.ms = 0
partitioner.class = null
partitioner.ignore.keys = false
receive.buffer.bytes = 32768
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = [hidden]
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = SCRAM-SHA-256
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = SASL_PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
transaction.timeout.ms = 60000
transactional.id = null
value.serializer = class org.apache.kafka.common.serialization.StringSerializer
2023-06-08 21:52:50,453 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=JMeter-Producer-1] Instantiated an idempotent producer.
2023-06-08 21:52:50,454 WARN o.a.k.c.ClientUtils: Couldn't resolve server broker:9092 from bootstrap.servers as DNS resolution failed for broker
2023-06-08 21:52:50,454 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=JMeter-Producer-1] Closing the Kafka producer with timeoutMillis = 0 ms.
2023-06-08 21:52:50,454 INFO o.a.k.c.m.Metrics: Metrics scheduler closed
2023-06-08 21:52:50,454 INFO o.a.k.c.m.Metrics: Closing reporter org.apache.kafka.common.metrics.JmxReporter
2023-06-08 21:52:50,454 INFO o.a.k.c.m.Metrics: Metrics reporters closed
2023-06-08 21:52:50,454 INFO o.a.k.c.u.AppInfoParser: App info kafka.producer for JMeter-Producer-1 unregistered
2023-06-08 21:52:50,454 ERROR c.d.j.k.c.KafkaProducerConfig: Error establishing Kafka producer client!
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:471) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:291) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:318) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:303) ~[kafka-clients-3.3.2.jar:?]
at com.di.jmeter.kafka.config.KafkaProducerConfig.testStarted(KafkaProducerConfig.java:81) ~[di-kafkameter-1.2.jar:?]
at org.apache.jmeter.engine.StandardJMeterEngine.notifyTestListenersOfStart(StandardJMeterEngine.java:218) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.engine.StandardJMeterEngine.run(StandardJMeterEngine.java:396) ~[ApacheJMeter_core.jar:5.5]
at java.lang.Thread.run(Thread.java:1623) ~[?:?]
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:89) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:445) ~[kafka-clients-3.3.2.jar:?]
... 7 more
2023-06-08 21:52:50,454 INFO o.a.j.g.u.JMeterMenuBar: setRunning(true, *local*)
2023-06-08 21:52:50,481 INFO o.a.j.e.StandardJMeterEngine: Starting ThreadGroup: 1 : Thread Group
2023-06-08 21:52:50,482 INFO o.a.j.e.StandardJMeterEngine: Starting 1 threads for group Thread Group.
2023-06-08 21:52:50,482 INFO o.a.j.e.StandardJMeterEngine: Thread will continue on error
2023-06-08 21:52:50,482 INFO o.a.j.t.ThreadGroup: Starting thread group... number=1 threads=1 ramp-up=1 delayedStart=false
2023-06-08 21:52:50,482 INFO o.a.j.t.ThreadGroup: Started thread group number 1
2023-06-08 21:52:50,482 INFO o.a.j.e.StandardJMeterEngine: All thread groups have been started
2023-06-08 21:52:50,482 INFO o.a.j.t.JMeterThread: Thread started: Thread Group 1-1
2023-06-08 21:52:50,482 INFO c.d.j.k.s.KafkaProducerSampler: Exception occurred while sending message to kafka
2023-06-08 21:52:50,483 ERROR o.a.j.s.SampleResult: setEndTime must be called after setStartTime
java.lang.Throwable: Invalid call sequence
at org.apache.jmeter.samplers.SampleResult.setEndTime(SampleResult.java:1107) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.samplers.SampleResult.sampleEnd(SampleResult.java:1145) ~[ApacheJMeter_core.jar:5.5]
at com.di.jmeter.kafka.sampler.KafkaProducerSampler.sample(KafkaProducerSampler.java:93) ~[di-kafkameter-1.2.jar:?]
at org.apache.jmeter.threads.JMeterThread.doSampling(JMeterThread.java:651) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.executeSamplePackage(JMeterThread.java:570) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.processSampler(JMeterThread.java:501) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:268) ~[ApacheJMeter_core.jar:5.5]
at java.lang.Thread.run(Thread.java:1623) ~[?:?]
2023-06-08 21:52:50,483 INFO o.a.j.t.JMeterThread: Thread is done: Thread Group 1-1
2023-06-08 21:52:50,483 INFO o.a.j.t.JMeterThread: Thread finished: Thread Group 1-1
2023-06-08 21:52:50,483 INFO o.a.j.e.StandardJMeterEngine: Notifying test listeners of end of test
2023-06-08 21:52:50,483 INFO o.a.j.g.u.JMeterMenuBar: setRunning(false, *local*)
2023-06-08 21:52:58,906 INFO o.a.j.e.StandardJMeterEngine: Running the test!
2023-06-08 21:52:58,906 INFO o.a.j.s.SampleEvent: List of sample_variables: []
2023-06-08 21:52:58,907 INFO c.d.j.k.c.KafkaProducerConfig: Setting up Additional properties
2023-06-08 21:52:58,907 INFO o.a.k.c.p.ProducerConfig: ProducerConfig values:
acks = -1
batch.size = 16384
bootstrap.servers = [broker:9092]
buffer.memory = 33554432
client.dns.lookup = use_all_dns_ips
client.id = JMeter-Producer-1
compression.type = none
connections.max.idle.ms = 540000
delivery.timeout.ms = 120000
enable.idempotence = true
interceptor.classes = []
key.serializer = class org.apache.kafka.common.serialization.StringSerializer
linger.ms = 0
max.block.ms = 60000
max.in.flight.requests.per.connection = 5
max.request.size = 1048576
metadata.max.age.ms = 300000
metadata.max.idle.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partitioner.adaptive.partitioning.enable = true
partitioner.availability.timeout.ms = 0
partitioner.class = null
partitioner.ignore.keys = false
receive.buffer.bytes = 32768
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = [hidden]
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = SCRAM-SHA-256
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = SASL_PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
transaction.timeout.ms = 60000
transactional.id = null
value.serializer = class org.apache.kafka.common.serialization.StringSerializer
2023-06-08 21:52:58,907 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=JMeter-Producer-1] Instantiated an idempotent producer.
2023-06-08 21:52:58,908 WARN o.a.k.c.ClientUtils: Couldn't resolve server broker:9092 from bootstrap.servers as DNS resolution failed for broker
2023-06-08 21:52:58,908 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=JMeter-Producer-1] Closing the Kafka producer with timeoutMillis = 0 ms.
2023-06-08 21:52:58,908 INFO o.a.k.c.m.Metrics: Metrics scheduler closed
2023-06-08 21:52:58,908 INFO o.a.k.c.m.Metrics: Closing reporter org.apache.kafka.common.metrics.JmxReporter
2023-06-08 21:52:58,908 INFO o.a.k.c.m.Metrics: Metrics reporters closed
2023-06-08 21:52:58,908 INFO o.a.k.c.u.AppInfoParser: App info kafka.producer for JMeter-Producer-1 unregistered
2023-06-08 21:52:58,908 ERROR c.d.j.k.c.KafkaProducerConfig: Error establishing Kafka producer client!
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:471) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:291) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:318) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:303) ~[kafka-clients-3.3.2.jar:?]
at com.di.jmeter.kafka.config.KafkaProducerConfig.testStarted(KafkaProducerConfig.java:81) ~[di-kafkameter-1.2.jar:?]
at org.apache.jmeter.engine.StandardJMeterEngine.notifyTestListenersOfStart(StandardJMeterEngine.java:218) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.engine.StandardJMeterEngine.run(StandardJMeterEngine.java:396) ~[ApacheJMeter_core.jar:5.5]
at java.lang.Thread.run(Thread.java:1623) ~[?:?]
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:89) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:445) ~[kafka-clients-3.3.2.jar:?]
... 7 more
2023-06-08 21:52:58,908 INFO o.a.j.g.u.JMeterMenuBar: setRunning(true, *local*)
2023-06-08 21:52:58,930 INFO o.a.j.e.StandardJMeterEngine: Starting ThreadGroup: 1 : Thread Group
2023-06-08 21:52:58,931 INFO o.a.j.e.StandardJMeterEngine: Starting 1 threads for group Thread Group.
2023-06-08 21:52:58,931 INFO o.a.j.e.StandardJMeterEngine: Thread will continue on error
2023-06-08 21:52:58,931 INFO o.a.j.t.ThreadGroup: Starting thread group... number=1 threads=1 ramp-up=1 delayedStart=false
2023-06-08 21:52:58,931 INFO o.a.j.t.ThreadGroup: Started thread group number 1
2023-06-08 21:52:58,931 INFO o.a.j.e.StandardJMeterEngine: All thread groups have been started
2023-06-08 21:52:58,931 INFO o.a.j.t.JMeterThread: Thread started: Thread Group 1-1
2023-06-08 21:52:58,932 INFO c.d.j.k.s.KafkaProducerSampler: Exception occurred while sending message to kafka
2023-06-08 21:52:58,932 ERROR o.a.j.s.SampleResult: setEndTime must be called after setStartTime
java.lang.Throwable: Invalid call sequence
at org.apache.jmeter.samplers.SampleResult.setEndTime(SampleResult.java:1107) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.samplers.SampleResult.sampleEnd(SampleResult.java:1145) ~[ApacheJMeter_core.jar:5.5]
at com.di.jmeter.kafka.sampler.KafkaProducerSampler.sample(KafkaProducerSampler.java:93) ~[di-kafkameter-1.2.jar:?]
at org.apache.jmeter.threads.JMeterThread.doSampling(JMeterThread.java:651) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.executeSamplePackage(JMeterThread.java:570) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.processSampler(JMeterThread.java:501) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:268) ~[ApacheJMeter_core.jar:5.5]
at java.lang.Thread.run(Thread.java:1623) ~[?:?]
2023-06-08 21:52:58,932 INFO o.a.j.t.JMeterThread: Thread is done: Thread Group 1-1
2023-06-08 21:52:58,932 INFO o.a.j.t.JMeterThread: Thread finished: Thread Group 1-1
2023-06-08 21:52:58,932 INFO o.a.j.e.StandardJMeterEngine: Notifying test listeners of end of test
2023-06-08 21:52:58,932 INFO o.a.j.g.u.JMeterMenuBar: setRunning(false, *local*)
2023-06-08 21:53:04,702 INFO o.a.j.e.StandardJMeterEngine: Running the test!
2023-06-08 21:53:04,702 INFO o.a.j.s.SampleEvent: List of sample_variables: []
2023-06-08 21:53:04,703 INFO c.d.j.k.c.KafkaProducerConfig: Setting up Additional properties
2023-06-08 21:53:04,703 INFO o.a.k.c.p.ProducerConfig: ProducerConfig values:
acks = -1
batch.size = 16384
bootstrap.servers = [broker:9092]
buffer.memory = 33554432
client.dns.lookup = use_all_dns_ips
client.id = JMeter-Producer-1
compression.type = none
connections.max.idle.ms = 540000
delivery.timeout.ms = 120000
enable.idempotence = true
interceptor.classes = []
key.serializer = class org.apache.kafka.common.serialization.StringSerializer
linger.ms = 0
max.block.ms = 60000
max.in.flight.requests.per.connection = 5
max.request.size = 1048576
metadata.max.age.ms = 300000
metadata.max.idle.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partitioner.adaptive.partitioning.enable = true
partitioner.availability.timeout.ms = 0
partitioner.class = null
partitioner.ignore.keys = false
receive.buffer.bytes = 32768
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = [hidden]
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = SCRAM-SHA-256
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = SASL_PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
transaction.timeout.ms = 60000
transactional.id = null
value.serializer = class org.apache.kafka.common.serialization.StringSerializer
2023-06-08 21:53:04,704 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=JMeter-Producer-1] Instantiated an idempotent producer.
2023-06-08 21:53:04,708 WARN o.a.k.c.ClientUtils: Couldn't resolve server broker:9092 from bootstrap.servers as DNS resolution failed for broker
2023-06-08 21:53:04,708 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=JMeter-Producer-1] Closing the Kafka producer with timeoutMillis = 0 ms.
2023-06-08 21:53:04,708 INFO o.a.k.c.m.Metrics: Metrics scheduler closed
2023-06-08 21:53:04,708 INFO o.a.k.c.m.Metrics: Closing reporter org.apache.kafka.common.metrics.JmxReporter
2023-06-08 21:53:04,708 INFO o.a.k.c.m.Metrics: Metrics reporters closed
2023-06-08 21:53:04,708 INFO o.a.k.c.u.AppInfoParser: App info kafka.producer for JMeter-Producer-1 unregistered
2023-06-08 21:53:04,708 ERROR c.d.j.k.c.KafkaProducerConfig: Error establishing Kafka producer client!
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:471) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:291) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:318) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:303) ~[kafka-clients-3.3.2.jar:?]
at com.di.jmeter.kafka.config.KafkaProducerConfig.testStarted(KafkaProducerConfig.java:81) ~[di-kafkameter-1.2.jar:?]
at org.apache.jmeter.engine.StandardJMeterEngine.notifyTestListenersOfStart(StandardJMeterEngine.java:218) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.engine.StandardJMeterEngine.run(StandardJMeterEngine.java:396) ~[ApacheJMeter_core.jar:5.5]
at java.lang.Thread.run(Thread.java:1623) ~[?:?]
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:89) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:48) ~[kafka-clients-3.3.2.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:445) ~[kafka-clients-3.3.2.jar:?]
... 7 more
2023-06-08 21:53:04,708 INFO o.a.j.g.u.JMeterMenuBar: setRunning(true, *local*)
2023-06-08 21:53:04,731 INFO o.a.j.e.StandardJMeterEngine: Starting ThreadGroup: 1 : Thread Group
2023-06-08 21:53:04,731 INFO o.a.j.e.StandardJMeterEngine: Starting 1 threads for group Thread Group.
2023-06-08 21:53:04,731 INFO o.a.j.e.StandardJMeterEngine: Thread will continue on error
2023-06-08 21:53:04,731 INFO o.a.j.t.ThreadGroup: Starting thread group... number=1 threads=1 ramp-up=1 delayedStart=false
2023-06-08 21:53:04,731 INFO o.a.j.t.ThreadGroup: Started thread group number 1
2023-06-08 21:53:04,732 INFO o.a.j.e.StandardJMeterEngine: All thread groups have been started
2023-06-08 21:53:04,732 INFO o.a.j.t.JMeterThread: Thread started: Thread Group 1-1
2023-06-08 21:53:04,732 INFO c.d.j.k.s.KafkaProducerSampler: Exception occurred while sending message to kafka
2023-06-08 21:53:04,732 ERROR o.a.j.s.SampleResult: setEndTime must be called after setStartTime
java.lang.Throwable: Invalid call sequence
at org.apache.jmeter.samplers.SampleResult.setEndTime(SampleResult.java:1107) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.samplers.SampleResult.sampleEnd(SampleResult.java:1145) ~[ApacheJMeter_core.jar:5.5]
at com.di.jmeter.kafka.sampler.KafkaProducerSampler.sample(KafkaProducerSampler.java:93) ~[di-kafkameter-1.2.jar:?]
at org.apache.jmeter.threads.JMeterThread.doSampling(JMeterThread.java:651) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.executeSamplePackage(JMeterThread.java:570) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.processSampler(JMeterThread.java:501) ~[ApacheJMeter_core.jar:5.5]
at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:268) ~[ApacheJMeter_core.jar:5.5]
at java.lang.Thread.run(Thread.java:1623) ~[?:?]
2023-06-08 21:53:04,732 INFO o.a.j.t.JMeterThread: Thread is done: Thread Group 1-1
2023-06-08 21:53:04,732 INFO o.a.j.t.JMeterThread: Thread finished: Thread Group 1-1
2023-06-08 21:53:04,732 INFO o.a.j.e.StandardJMeterEngine: Notifying test listeners of end of test
2023-06-08 21:53:04,733 INFO o.a.j.g.u.JMeterMenuBar: setRunning(false, *local*)
2023-06-08 21:54:42,466 INFO o.a.j.e.StandardJMeterEngine: Running the test!
2023-06-08 21:54:42,467 INFO o.a.j.s.SampleEvent: List of sample_variables: []
2023-06-08 21:54:42,468 INFO c.d.j.k.c.KafkaProducerConfig: Setting up Additional properties
2023-06-08 21:54:42,469 INFO o.a.k.c.p.ProducerConfig: ProducerConfig values:
acks = -1
batch.size = 16384
bootstrap.servers = [broker:9092]
buffer.memory = 33554432
client.dns.lookup = use_all_dns_ips
client.id = JMeter-Producer-1
compression.type = none
connections.max.idle.ms = 540000
delivery.timeout.ms = 120000
enable.idempotence = true
interceptor.classes = []
key.serializer = class org.apache.kafka.common.serialization.StringSerializer
linger.ms = 0
max.block.ms = 60000
max.in.flight.requests.per.connection = 5
max.request.size = 1048576
metadata.max.age.ms = 300000
metadata.max.idle.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partitioner.adaptive.partitioning.enable = true
partitioner.availability.timeout.ms = 0
partitioner.class = null
partitioner.ignore.keys = false
receive.buffer.bytes = 32768
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = [hidden]
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = SCRAM-SHA-256
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = SASL_PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
transaction.timeout.ms = 60000
transactional.id = null
value.serializer = class org.apache.kafka.common.serialization.StringSerializer