search

rollno748 / di-kafkameter

JMeter Plugin to load test Apache Kafka topics/brokers
34 stars 11 forks source link

Response code:500 cannot send message to the local Kafka broker #15

Closed kamal2222ahmed closed 1 year ago

kamal2222ahmed commented 1 year ago

I have installed docker-compose based local server on Mac

 % docker-compose ps
NAME                IMAGE                             COMMAND                  SERVICE             CREATED             STATUS              PORTS
broker              confluentinc/cp-kafka:7.3.2       "/etc/confluent/dock…"   broker              2 days ago          Up 2 days           0.0.0.0:9092->9092/tcp, :::9092->9092/tcp
zookeeper           confluentinc/cp-zookeeper:7.3.2   "/etc/confluent/dock…"   zookeeper           2 days ago          Up 2 days           2181/tcp, 2888/tcp, 3888/tcp
(base) syedahmed:Confluent-Docker-Kafka % cat docker-compose.yml
---
version: '3'
services:
  zookeeper:
    image: confluentinc/cp-zookeeper:7.3.2
    container_name: zookeeper
    environment:
      ZOOKEEPER_CLIENT_PORT: 2181
      ZOOKEEPER_TICK_TIME: 2000

  broker:
    image: confluentinc/cp-kafka:7.3.2
    container_name: broker
    ports:
    # To learn about configuring Kafka for access across networks see
    # https://www.confluent.io/blog/kafka-client-cannot-connect-to-broker-on-aws-on-docker-etc/
      - "9092:9092"
    depends_on:
      - zookeeper
    environment:
      KAFKA_BROKER_ID: 1
      KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_INTERNAL:PLAINTEXT
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092,PLAINTEXT_INTERNAL://broker:29092
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
      KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
      KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1

here is meter.log

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
kamal2222ahmed commented 1 year ago 
Maven home: /opt/homebrew/Cellar/maven/3.9.2/libexec
Java version: 20.0.1, vendor: Oracle Corporation, runtime: /Library/Java/JavaVirtualMachines/jdk-20.jdk/Contents/Home
Default locale: en_US, platform encoding: UTF-8
OS name: "mac os x", version: "13.4", arch: "aarch64", family: "Mac"
rollno748 commented 1 year ago

Hey, I don't see its an issue with the plugin - it is with your config you have passed

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

The above message clearly shows that - it was unable to resolve the DNS, hence it is failed to construct the producer

My suggestions:

  1. Update your hosts file for dns resolver
  2. Use IP instead of hostname (use 127.0.0.1 or 0.0.0.0 for localhost)

A sample screenshot of your kafka producer config would help us to understand the exact root cause

rollno748 commented 1 year ago

Hello @kamal2222ahmed

Is there any update on the issue ?

rollno748 commented 1 year ago

Hello @kamal2222ahmed

Do you have update on this or you still experience the issue ?

rollno748 commented 1 year ago

Hey @kamal2222ahmed

I haven't received any further communication from your end - so, I consider that as a positive sign and closing it Feel free to reopen - if you still face the issue