Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[Issue]: sasl.jaas.config property is not applied #435

Open
2 tasks done
mavdey opened this issue Feb 26, 2024 · 4 comments
Open
2 tasks done

[Issue]: sasl.jaas.config property is not applied #435

mavdey opened this issue Feb 26, 2024 · 4 comments

Comments

@mavdey
Copy link

mavdey commented Feb 26, 2024

What happened?

I use security.protocol SASL_PLAINTEXT.
When I run the test, I see in the log that plaintext is being used.

security.protocol property isn't applied,
sasl.jaas.config property is not applied.

I tried KLoadGen 5.6.12 and 5.6.10. Both are working same.

JMeter version 5.6.2.

test_plan.zip

KloadGen Version

KLoadGen 5.6.12 and KLoadGen 5.6.10 from maven

Relevant log output

2024-02-26 18:13:24,785 INFO o.a.j.u.JMeterUtils: Setting Locale to ru_RU
2024-02-26 18:13:24,852 ERROR o.a.j.u.JMeterUtils: Could not find resources for 'ru_RU'
2024-02-26 18:13:24,857 INFO o.a.j.JMeter: Loading user properties from: user.properties
2024-02-26 18:13:24,866 INFO o.a.j.JMeter: Loading system properties from: C:\Users\MMAvdeev\jmeter\apache-jmeter-5.6.2\bin\system.properties
2024-02-26 18:13:24,875 INFO o.a.j.JMeter: Copyright (c) 1998-2023 The Apache Software Foundation
2024-02-26 18:13:24,875 INFO o.a.j.JMeter: Version 5.6.2
2024-02-26 18:13:24,875 INFO o.a.j.JMeter: java.version=21.0.1
2024-02-26 18:13:24,875 INFO o.a.j.JMeter: java.vm.name=OpenJDK 64-Bit Server VM
2024-02-26 18:13:24,875 INFO o.a.j.JMeter: os.name=Windows 10
2024-02-26 18:13:24,876 INFO o.a.j.JMeter: os.arch=amd64
2024-02-26 18:13:24,876 INFO o.a.j.JMeter: os.version=10.0
2024-02-26 18:13:24,876 INFO o.a.j.JMeter: file.encoding=UTF-8
2024-02-26 18:13:24,876 INFO o.a.j.JMeter: java.awt.headless=null
2024-02-26 18:13:24,876 INFO o.a.j.JMeter: Max memory     =3221225472
2024-02-26 18:13:24,876 INFO o.a.j.JMeter: Available Processors =2
2024-02-26 18:13:24,892 INFO o.a.j.JMeter: Default Locale=русский (Россия)
2024-02-26 18:13:24,893 INFO o.a.j.JMeter: JMeter  Locale=русский (Россия)
2024-02-26 18:13:24,894 INFO o.a.j.JMeter: JMeterHome=C:\Users\MMAvdeev\jmeter\apache-jmeter-5.6.2
2024-02-26 18:13:24,894 INFO o.a.j.JMeter: user.dir  =C:\Users\MMAvdeev\jmeter
2024-02-26 18:13:24,895 INFO o.a.j.JMeter: PWD       =C:\Users\MMAvdeev\jmeter
2024-02-26 18:13:24,896 INFO o.a.j.JMeter: IP: 10.50.15.152 Name: MS-VDI001-1171 FullName: MS-VDI001-1171.bee.vimpelcom.ru
2024-02-26 18:13:24,931 INFO o.a.j.JMeter: Loaded icon properties from org/apache/jmeter/images/icon.properties
2024-02-26 18:13:25,199 INFO o.a.j.JMeterGuiLauncher: Setting LAF to: com.github.weisj.darklaf.DarkLaf:com.github.weisj.darklaf.theme.DarculaTheme
2024-02-26 18:13:27,462 INFO o.a.j.r.ClassFinder: Will scan jar C:\Users\MMAvdeev\jmeter\apache-jmeter-5.6.2\lib\ext\kloadgen-5.6.12.jar with filter ExtendsClassFilter [parents=[interface org.apache.jmeter.gui.action.Command], inner=false, contains=null, notContains=null]. Consider exposing JMeter plugins via META-INF/services, and add JMeter-Skip-Class-Scanning=true manifest attribute so JMeter can skip classfile scanning
2024-02-26 18:13:32,538 INFO o.a.j.r.ClassFinder: Will scan jar C:\Users\MMAvdeev\jmeter\apache-jmeter-5.6.2\lib\ext\kloadgen-5.6.12.jar with filter ExtendsClassFilter [parents=[interface org.apache.jmeter.gui.plugin.MenuCreator], inner=false, contains=null, notContains=null]. Consider exposing JMeter plugins via META-INF/services, and add JMeter-Skip-Class-Scanning=true manifest attribute so JMeter can skip classfile scanning
2024-02-26 18:13:59,084 INFO o.a.j.s.FileServer: Default base='C:\Users\MMAvdeev\jmeter'
2024-02-26 18:13:59,088 INFO o.a.j.g.a.Load: Loading file: C:\Users\MMAvdeev\Desktop\legal\test_plan.jmx
2024-02-26 18:13:59,088 INFO o.a.j.s.FileServer: Set new base='C:\Users\MMAvdeev\Desktop\legal'
2024-02-26 18:13:59,404 INFO o.a.j.s.SaveService: Testplan (JMX) version: 2.2. Testlog (JTL) version: 2.2
2024-02-26 18:13:59,452 INFO o.a.j.s.SaveService: Using SaveService properties version 5.0
2024-02-26 18:13:59,454 INFO o.a.j.s.SaveService: Using SaveService properties file encoding UTF-8
2024-02-26 18:13:59,460 INFO o.a.j.s.SaveService: Loading file: C:\Users\MMAvdeev\Desktop\legal\test_plan.jmx
2024-02-26 18:14:02,365 INFO o.r.Reflections: Reflections took 2659 ms to scan 1 urls, producing 4225 keys and 21730 values
2024-02-26 18:14:04,507 INFO o.r.Reflections: Reflections took 1942 ms to scan 1 urls, producing 4225 keys and 21730 values
2024-02-26 18:14:04,657 INFO o.r.Reflections: Reflections took 102 ms to scan 1 urls, producing 34 keys and 78 values
2024-02-26 18:14:04,818 INFO o.a.j.r.ClassFinder: Will scan jar C:\Users\MMAvdeev\jmeter\apache-jmeter-5.6.2\lib\ext\kloadgen-5.6.12.jar with filter ExtendsClassFilter [parents=[interface org.apache.jmeter.protocol.java.sampler.JavaSamplerClient], inner=false, contains=null, notContains=null]. Consider exposing JMeter plugins via META-INF/services, and add JMeter-Skip-Class-Scanning=true manifest attribute so JMeter can skip classfile scanning
2024-02-26 18:14:04,989 INFO o.a.j.s.SampleResult: Note: Sample TimeStamps are START times
2024-02-26 18:14:04,989 INFO o.a.j.s.SampleResult: sampleresult.default.encoding is set to UTF-8
2024-02-26 18:14:04,989 INFO o.a.j.s.SampleResult: sampleresult.useNanoTime=true
2024-02-26 18:14:04,990 INFO o.a.j.s.SampleResult: sampleresult.nanoThreadSleep=5000
2024-02-26 18:14:05,016 INFO o.a.j.r.ClassFinder: Will scan jar C:\Users\MMAvdeev\jmeter\apache-jmeter-5.6.2\lib\ext\kloadgen-5.6.12.jar with filter ExtendsClassFilter [parents=[interface org.apache.jmeter.visualizers.ResultRenderer], inner=false, contains=null, notContains=null]. Consider exposing JMeter plugins via META-INF/services, and add JMeter-Skip-Class-Scanning=true manifest attribute so JMeter can skip classfile scanning
2024-02-26 18:14:05,144 INFO o.a.j.r.ClassFinder: Will scan jar C:\Users\MMAvdeev\jmeter\apache-jmeter-5.6.2\lib\ext\kloadgen-5.6.12.jar with filter ExtendsClassFilter [parents=[interface org.apache.jmeter.visualizers.RequestView], inner=false, contains=null, notContains=null]. Consider exposing JMeter plugins via META-INF/services, and add JMeter-Skip-Class-Scanning=true manifest attribute so JMeter can skip classfile scanning
2024-02-26 18:14:05,323 INFO o.a.j.s.FileServer: Set new base='C:\Users\MMAvdeev\Desktop\legal'
2024-02-26 18:14:14,278 INFO o.a.j.e.StandardJMeterEngine: Running the test!
2024-02-26 18:14:14,279 INFO o.a.j.s.SampleEvent: List of sample_variables: []
2024-02-26 18:14:14,279 INFO o.a.j.s.SampleEvent: List of sample_variables: []
2024-02-26 18:14:14,282 INFO o.a.j.e.u.CompoundVariable: Note: Function class names must contain the string: '.functions.'
2024-02-26 18:14:14,282 INFO o.a.j.e.u.CompoundVariable: Note: Function class names must not contain the string: '.gui.'
2024-02-26 18:14:14,370 INFO o.a.j.r.ClassFinder: Will scan jar C:\Users\MMAvdeev\jmeter\apache-jmeter-5.6.2\lib\ext\kloadgen-5.6.12.jar with filter ExtendsClassFilter [parents=[interface org.apache.jmeter.functions.Function], inner=false, contains=null, notContains=null]. Consider exposing JMeter plugins via META-INF/services, and add JMeter-Skip-Class-Scanning=true manifest attribute so JMeter can skip classfile scanning
2024-02-26 18:14:14,479 INFO o.a.j.p.j.s.JavaSampler: Created class: com.sngular.kloadgen.sampler.KafkaProducerSampler. Uses tearDownTest: 
2024-02-26 18:14:14,481 INFO o.a.j.g.u.JMeterMenuBar: setRunning(true, *local*)
2024-02-26 18:14:14,609 INFO o.a.j.e.StandardJMeterEngine: Starting ThreadGroup: 1 : Thread Group
2024-02-26 18:14:14,609 INFO o.a.j.e.StandardJMeterEngine: Starting 1 threads for group Thread Group.
2024-02-26 18:14:14,609 INFO o.a.j.e.StandardJMeterEngine: Thread will continue on error
2024-02-26 18:14:14,610 INFO o.a.j.t.ThreadGroup: Starting thread group... number=1 threads=1 ramp-up=1 delayedStart=false
2024-02-26 18:14:14,622 INFO o.a.j.t.ThreadGroup: Started thread group number 1
2024-02-26 18:14:14,622 INFO o.a.j.e.StandardJMeterEngine: All thread groups have been started
2024-02-26 18:14:14,643 INFO o.a.j.t.JMeterThread: Thread started: Thread Group 1-1
2024-02-26 18:14:14,645 INFO o.a.j.s.FileServer: Stored: C:/Users/MMAvdeev/Desktop/legal/mark20000.csv
2024-02-26 18:14:14,766 INFO o.a.k.c.p.ProducerConfig: ProducerConfig values: 
	acks = -1
	auto.include.jmx.reporter = true
	batch.size = 16384
	bootstrap.servers = [kfk-dev-03.dmp.vimpelcom.ru:6667]
	buffer.memory = 33554432
	client.dns.lookup = use_all_dns_ips
	client.id = 
	compression.type = none
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 120000
	enable.idempotence = true
	interceptor.classes = []
	key.serializer = class com.sngular.kloadgen.serializer.AvroSerializer
	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 = null
	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 = GSSAPI
	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 = 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 io.confluent.kafka.serializers.KafkaAvroSerializer

2024-02-26 18:14:14,769 TRACE o.a.k.c.p.KafkaProducer: [Producer clientId=] Starting the Kafka producer
2024-02-26 18:14:14,809 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=] Instantiated an idempotent producer.
2024-02-26 18:14:15,058 INFO o.a.k.c.p.ProducerConfig: These configurations '[jdbc.config.jdbc.driver.class, beanshell.server.file, htmlParser.className, jmeter.reportgenerator.apdex_satisfied_threshold, htmlParser.types, cookies, classfinder.functions.contain, wmlParser.className, server.rmi.ssl.disable, classfinder.functions.notContain, system.properties, jdbc.config.check.query, cssParser.types, summariser.name, gui.quick_6, wmlParser.types, START.HMS, gui.quick_5, view.results.tree.renderers_order, gui.quick_8, csvdataset.file.encoding_list, user.properties, gui.quick_7, upgrade_properties, cssParser.className, jmeter.reportgenerator.apdex_tolerated_threshold, gui.quick_9, sampleresult.timestamp.start, START.YMD, START.MS, TESTSTART.MS, not_in_menu, gui.quick_0, gui.quick_2, gui.quick_1, gui.quick_4, HTTPResponse.parsers, gui.quick_3, remote_hosts, jmeter.version]' were supplied but are not used yet.
2024-02-26 18:14:15,060 INFO o.a.k.c.u.AppInfoParser: Kafka version: 3.5.1
2024-02-26 18:14:15,060 INFO o.a.k.c.u.AppInfoParser: Kafka commitId: 2c6fb6c54472e90a
2024-02-26 18:14:15,060 INFO o.a.k.c.u.AppInfoParser: Kafka startTimeMs: 1708960455058
2024-02-26 18:14:15,064 DEBUG o.a.k.c.p.KafkaProducer: [Producer clientId=] Kafka producer started
2024-02-26 18:14:15,079 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Starting Kafka producer I/O thread.
2024-02-26 18:14:15,121 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Transition from state UNINITIALIZED to INITIALIZING
2024-02-26 18:14:15,419 TRACE o.a.k.c.p.KafkaProducer: [Producer clientId=] Requesting metadata update for topic legal_markcp_nezaregi_dev.
2024-02-26 18:14:15,442 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:15,442 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:15,569 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 2
2024-02-26 18:14:15,678 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:15,680 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 1 due to node -1 being disconnected (elapsed time since creation: 112ms, elapsed time since send: 112ms, request timeout: 30000ms)
2024-02-26 18:14:15,682 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 2 due to node -1 being disconnected (elapsed time since creation: 109ms, elapsed time since send: 109ms, request timeout: 30000ms)
2024-02-26 18:14:15,683 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:15,694 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:15,694 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:15,695 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:15,695 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:15,695 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:15,778 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:15,902 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 5
2024-02-26 18:14:15,905 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:15,906 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 4 due to node -1 being disconnected (elapsed time since creation: 105ms, elapsed time since send: 105ms, request timeout: 30000ms)
2024-02-26 18:14:15,906 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 5 due to node -1 being disconnected (elapsed time since creation: 3ms, elapsed time since send: 3ms, request timeout: 30000ms)
2024-02-26 18:14:15,906 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:15,906 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:15,906 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:15,906 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:15,906 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:15,906 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:16,050 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:16,170 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 8
2024-02-26 18:14:16,175 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:16,175 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 7 due to node -1 being disconnected (elapsed time since creation: 107ms, elapsed time since send: 107ms, request timeout: 30000ms)
2024-02-26 18:14:16,176 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 8 due to node -1 being disconnected (elapsed time since creation: 5ms, elapsed time since send: 5ms, request timeout: 30000ms)
2024-02-26 18:14:16,176 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:16,176 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:16,176 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:16,176 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:16,176 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:16,176 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:16,276 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:16,405 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 11
2024-02-26 18:14:16,409 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:16,409 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 10 due to node -1 being disconnected (elapsed time since creation: 107ms, elapsed time since send: 107ms, request timeout: 30000ms)
2024-02-26 18:14:16,409 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 11 due to node -1 being disconnected (elapsed time since creation: 4ms, elapsed time since send: 4ms, request timeout: 30000ms)
2024-02-26 18:14:16,409 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:16,409 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:16,410 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:16,410 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:16,410 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:16,410 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:16,509 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:16,648 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 14
2024-02-26 18:14:16,652 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:16,652 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 13 due to node -1 being disconnected (elapsed time since creation: 107ms, elapsed time since send: 107ms, request timeout: 30000ms)
2024-02-26 18:14:16,652 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 14 due to node -1 being disconnected (elapsed time since creation: 4ms, elapsed time since send: 4ms, request timeout: 30000ms)
2024-02-26 18:14:16,652 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:16,653 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:16,653 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:16,653 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:16,653 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:16,653 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:16,755 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:16,881 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 17
2024-02-26 18:14:16,886 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:16,887 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 16 due to node -1 being disconnected (elapsed time since creation: 107ms, elapsed time since send: 107ms, request timeout: 30000ms)
2024-02-26 18:14:16,887 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 17 due to node -1 being disconnected (elapsed time since creation: 5ms, elapsed time since send: 5ms, request timeout: 30000ms)
2024-02-26 18:14:16,887 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:16,887 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:16,887 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:16,887 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:16,887 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:16,887 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:16,986 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:17,124 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 20
2024-02-26 18:14:17,127 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:17,127 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 19 due to node -1 being disconnected (elapsed time since creation: 106ms, elapsed time since send: 106ms, request timeout: 30000ms)
2024-02-26 18:14:17,127 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 20 due to node -1 being disconnected (elapsed time since creation: 3ms, elapsed time since send: 3ms, request timeout: 30000ms)
2024-02-26 18:14:17,127 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:17,128 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:17,128 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:17,129 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:17,129 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:17,129 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:17,229 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:17,350 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 23
2024-02-26 18:14:17,354 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:17,355 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 22 due to node -1 being disconnected (elapsed time since creation: 106ms, elapsed time since send: 106ms, request timeout: 30000ms)
2024-02-26 18:14:17,355 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 23 due to node -1 being disconnected (elapsed time since creation: 4ms, elapsed time since send: 4ms, request timeout: 30000ms)
2024-02-26 18:14:17,355 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:17,355 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:17,356 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:17,356 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:17,356 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:17,356 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:17,455 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:17,584 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 26
2024-02-26 18:14:17,590 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:17,590 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 25 due to node -1 being disconnected (elapsed time since creation: 107ms, elapsed time since send: 107ms, request timeout: 30000ms)
2024-02-26 18:14:17,590 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 26 due to node -1 being disconnected (elapsed time since creation: 6ms, elapsed time since send: 6ms, request timeout: 30000ms)
2024-02-26 18:14:17,590 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:17,590 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:17,590 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:17,590 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:17,590 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:17,591 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:17,690 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:17,816 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 29
2024-02-26 18:14:17,820 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:17,820 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 28 due to node -1 being disconnected (elapsed time since creation: 105ms, elapsed time since send: 105ms, request timeout: 30000ms)
2024-02-26 18:14:17,820 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 29 due to node -1 being disconnected (elapsed time since creation: 4ms, elapsed time since send: 4ms, request timeout: 30000ms)
2024-02-26 18:14:17,820 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:17,821 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:17,821 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:17,821 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:17,821 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:17,821 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:17,921 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:18,053 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 32
2024-02-26 18:14:18,059 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:18,060 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 31 due to node -1 being disconnected (elapsed time since creation: 108ms, elapsed time since send: 108ms, request timeout: 30000ms)
2024-02-26 18:14:18,060 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 32 due to node -1 being disconnected (elapsed time since creation: 6ms, elapsed time since send: 6ms, request timeout: 30000ms)
2024-02-26 18:14:18,060 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:18,060 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:18,061 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:18,061 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:18,061 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:18,061 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:18,159 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:18,287 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 35
2024-02-26 18:14:18,292 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:18,293 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 34 due to node -1 being disconnected (elapsed time since creation: 107ms, elapsed time since send: 107ms, request timeout: 30000ms)
2024-02-26 18:14:18,293 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 35 due to node -1 being disconnected (elapsed time since creation: 5ms, elapsed time since send: 5ms, request timeout: 30000ms)
2024-02-26 18:14:18,293 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:18,293 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:18,293 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:18,293 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:18,293 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:18,293 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:18,392 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:18,520 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 38
2024-02-26 18:14:18,527 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:18,529 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 37 due to node -1 being disconnected (elapsed time since creation: 108ms, elapsed time since send: 108ms, request timeout: 30000ms)
2024-02-26 18:14:18,529 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 38 due to node -1 being disconnected (elapsed time since creation: 7ms, elapsed time since send: 7ms, request timeout: 30000ms)
2024-02-26 18:14:18,529 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:18,529 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:18,529 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:18,529 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:18,529 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:18,529 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:18,628 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:18,753 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 41
2024-02-26 18:14:18,758 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:18,758 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 40 due to node -1 being disconnected (elapsed time since creation: 107ms, elapsed time since send: 107ms, request timeout: 30000ms)
2024-02-26 18:14:18,759 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 41 due to node -1 being disconnected (elapsed time since creation: 5ms, elapsed time since send: 5ms, request timeout: 30000ms)
2024-02-26 18:14:18,759 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:18,759 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:18,759 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:18,759 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:18,759 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:18,760 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:18,858 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:18,986 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 44
2024-02-26 18:14:18,993 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:18,993 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 43 due to node -1 being disconnected (elapsed time since creation: 108ms, elapsed time since send: 108ms, request timeout: 30000ms)
2024-02-26 18:14:18,993 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 44 due to node -1 being disconnected (elapsed time since creation: 6ms, elapsed time since send: 6ms, request timeout: 30000ms)
2024-02-26 18:14:18,993 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:18,994 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:18,994 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:18,994 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:18,995 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:18,995 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:19,092 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:19,218 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 47
2024-02-26 18:14:19,223 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:19,224 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 46 due to node -1 being disconnected (elapsed time since creation: 106ms, elapsed time since send: 106ms, request timeout: 30000ms)
2024-02-26 18:14:19,224 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 47 due to node -1 being disconnected (elapsed time since creation: 5ms, elapsed time since send: 5ms, request timeout: 30000ms)
2024-02-26 18:14:19,224 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:19,224 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:19,224 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:19,224 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:19,226 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:19,226 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:19,328 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:19,453 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 50
2024-02-26 18:14:19,459 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:19,460 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 49 due to node -1 being disconnected (elapsed time since creation: 107ms, elapsed time since send: 107ms, request timeout: 30000ms)
2024-02-26 18:14:19,460 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 50 due to node -1 being disconnected (elapsed time since creation: 6ms, elapsed time since send: 6ms, request timeout: 30000ms)
2024-02-26 18:14:19,461 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:19,461 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:19,462 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:19,464 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:19,469 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:19,470 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:19,559 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:19,678 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 53
2024-02-26 18:14:19,683 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:19,684 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 52 due to node -1 being disconnected (elapsed time since creation: 107ms, elapsed time since send: 107ms, request timeout: 30000ms)
2024-02-26 18:14:19,684 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 53 due to node -1 being disconnected (elapsed time since creation: 5ms, elapsed time since send: 5ms, request timeout: 30000ms)
2024-02-26 18:14:19,684 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:19,684 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:19,684 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:19,684 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:19,684 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:19,686 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:19,784 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:19,912 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 56
2024-02-26 18:14:19,917 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:19,917 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 55 due to node -1 being disconnected (elapsed time since creation: 106ms, elapsed time since send: 106ms, request timeout: 30000ms)
2024-02-26 18:14:19,918 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 56 due to node -1 being disconnected (elapsed time since creation: 5ms, elapsed time since send: 5ms, request timeout: 30000ms)
2024-02-26 18:14:19,918 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:19,918 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:19,918 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:19,918 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:19,918 TRACE o.a.k.c.p.i.Sender: [Producer clientId=] No nodes available to send requests, will poll and retry when until a node is ready.
2024-02-26 18:14:19,918 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:20,017 TRACE o.a.k.c.p.i.TransactionManager: [Producer clientId=] Request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) dequeued for sending
2024-02-26 18:14:20,025 INFO o.a.j.g.a.Start: Stopping test
2024-02-26 18:14:20,040 INFO o.a.j.t.JMeterThread: Stopping: Thread Group 1-1
2024-02-26 18:14:20,049 WARN o.a.j.t.JMeterThread: Interrupting: Thread Group 1-1 sampler: Kafka Producer Properties
2024-02-26 18:14:20,050 WARN o.a.j.t.JMeterThread: No operation pending
2024-02-26 18:14:20,050 ERROR o.a.j.t.JMeterThread: Error while processing sampler: 'Kafka Producer Properties'.
org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:1088) ~[kloadgen-5.6.12.jar:?]
	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:962) ~[kloadgen-5.6.12.jar:?]
	at com.sngular.kloadgen.sampler.KafkaProducerSampler.runTest(KafkaProducerSampler.java:146) ~[kloadgen-5.6.12.jar:?]
	at org.apache.jmeter.protocol.java.sampler.JavaSampler.sample(JavaSampler.java:197) ~[ApacheJMeter_java.jar:5.6.2]
	at org.apache.jmeter.threads.JMeterThread.doSampling(JMeterThread.java:651) ~[ApacheJMeter_core.jar:5.6.2]
	at org.apache.jmeter.threads.JMeterThread.executeSamplePackage(JMeterThread.java:570) ~[ApacheJMeter_core.jar:5.6.2]
	at org.apache.jmeter.threads.JMeterThread.processSampler(JMeterThread.java:501) ~[ApacheJMeter_core.jar:5.6.2]
	at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:268) ~[ApacheJMeter_core.jar:5.6.2]
	at java.lang.Thread.run(Thread.java:1583) [?:?]
Caused by: java.lang.InterruptedException
	at java.lang.Object.wait0(Native Method) ~[?:?]
	at java.lang.Object.wait(Object.java:366) ~[?:?]
	at org.apache.kafka.common.utils.SystemTime.waitObject(SystemTime.java:55) ~[kloadgen-5.6.12.jar:?]
	at org.apache.kafka.clients.producer.internals.ProducerMetadata.awaitUpdate(ProducerMetadata.java:119) ~[kloadgen-5.6.12.jar:?]
	at org.apache.kafka.clients.producer.KafkaProducer.waitOnMetadata(KafkaProducer.java:1147) ~[kloadgen-5.6.12.jar:?]
	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:996) ~[kloadgen-5.6.12.jar:?]
	... 8 more
2024-02-26 18:14:20,080 INFO o.a.j.t.JMeterThread: Thread is done: Thread Group 1-1
2024-02-26 18:14:20,080 INFO o.a.j.t.JMeterThread: Thread finished: Thread Group 1-1
2024-02-26 18:14:20,080 INFO o.a.j.e.StandardJMeterEngine: Notifying test listeners of end of test
2024-02-26 18:14:20,080 INFO o.a.j.s.FileServer: Close: C:/Users/MMAvdeev/Desktop/legal/mark20000.csv
2024-02-26 18:14:20,082 INFO o.a.k.c.p.KafkaProducer: [Producer clientId=] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
2024-02-26 18:14:20,147 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Sending transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1) to node kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) with correlation ID 59
2024-02-26 18:14:20,147 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Beginning shutdown of Kafka producer I/O thread, sending remaining records.
2024-02-26 18:14:20,152 INFO o.a.k.c.NetworkClient: [Producer clientId=] Node -1 disconnected.
2024-02-26 18:14:20,153 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight METADATA request with correlation id 58 due to node -1 being disconnected (elapsed time since creation: 106ms, elapsed time since send: 106ms, request timeout: 30000ms)
2024-02-26 18:14:20,153 INFO o.a.k.c.NetworkClient: [Producer clientId=] Cancelled in-flight INIT_PRODUCER_ID request with correlation id 59 due to node -1 being disconnected (elapsed time since creation: 5ms, elapsed time since send: 5ms, request timeout: 30000ms)
2024-02-26 18:14:20,153 WARN o.a.k.c.NetworkClient: [Producer clientId=] Bootstrap broker kfk-dev-03.dmp.vimpelcom.ru:6667 (id: -1 rack: null) disconnected
2024-02-26 18:14:20,153 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Disconnected from -1. Will retry.
2024-02-26 18:14:20,153 DEBUG o.a.k.c.p.i.TransactionManager: [Producer clientId=] Enqueuing transactional request InitProducerIdRequestData(transactionalId=null, transactionTimeoutMs=2147483647, producerId=-1, producerEpoch=-1)
2024-02-26 18:14:20,157 DEBUG o.a.k.c.p.i.Sender: [Producer clientId=] Shutdown of Kafka producer I/O thread has completed.
2024-02-26 18:14:20,170 INFO o.a.k.c.m.Metrics: Metrics scheduler closed
2024-02-26 18:14:20,171 INFO o.a.k.c.m.Metrics: Closing reporter org.apache.kafka.common.metrics.JmxReporter
2024-02-26 18:14:20,171 INFO o.a.k.c.m.Metrics: Metrics reporters closed
2024-02-26 18:14:20,171 INFO o.a.k.c.u.AppInfoParser: App info kafka.producer for  unregistered
2024-02-26 18:14:20,171 DEBUG o.a.k.c.p.KafkaProducer: [Producer clientId=] Kafka producer has been closed
2024-02-26 18:14:20,171 INFO o.a.j.g.u.JMeterMenuBar: setRunning(false, *local*)

Have you added your JMX Testplan or a replica?

  • I have added a JMX testplan

Have you added your Schema or a replica?

  • I have added the Schema
@github-actions GitHub Actions
Copy link

Thank you for collaborating with the project by giving us feedback! In case it applies, it would be helpful if you could attach an example AVRO and an example test plan for us to reproduce the error. Cheers!

@mavdey
Copy link
Author

mavdey commented Feb 26, 2024

Scheme:

{
"type": "record",
"name": "CPForMarking",
"namespace": "ru.beeline.customer.datamarts",
"fields": [
{
"name": "ctn",
"type": "string"
},
{
"name": "customer_id",
"type": "long"
},
{
"name": "subscriber_id",
"type": "long"
},
{
"name": "indicator_id",
"type": "string"
},
{
"name": "iw_value",
"type": "string"
},
{
"name": "calc_date",
"type": "string"
},
{
"name": "operation",
"type": "string"
}
]
}

@TheMonsther
Copy link

TheMonsther commented Jul 17, 2024 •
edited
Loading

I'm facing the exact same error for Confluent connection.

Here's my test plan
Screenshot 2024-07-17 at 19 30 18

Here's my producer properties.
Screenshot 2024-07-17 at 19 32 45

As far as I know the data typed in the properties aren't correctly written on ProducerConfig.

Here's my producerConfig values (present in the logs)

buffer.memory = 33554432
	client.dns.lookup = use_all_dns_ips
	client.id = lkc-3j2jw
	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 = null
	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 = GSSAPI
	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 = 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 com.sngular.kloadgen.serializer.AvroSerializer```

@TheMonsther
Copy link

Fixed.

I had to use the standalone version and add directly in the java class the parameter for the auth.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@TheMonsther @mavdey