[Issue]: `sasl.jaas.config` property is not applied about kloadgen HOT 5 CLOSED

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!

from kloadgen.

Please, can you try with the property java.security.auth.login.config? It can directly take the value:

KafkaClient {
 org.apache.kafka.common.security.scram.ScramLoginModule required username="{username}" password="{password}";
};

or even a path to the config file containing this information.

from kloadgen.

@amondacaSN I have tried this mechanism, but the issue is that I still get no logs. I chose "ALL," and I cannot see if the producer sends any requests to Kafka.

• Does it mean that there is no HTTP request ever sent? Do you think it should be sent?
• How do I know that connection is established correctly?
• What steps can I try to make it work/debug further?

from kloadgen.

@ChameleonTartu if you do not see any error log lines, probably this means that the HTTP request has been sent succesfully, because error level logs are active by default.
However, if you want to debug something related to KafkaProducer more depth, then you should config KafkaProducer logger in trace level. This can be done by adding this line to the Jmeter log4j2 config file (located in the bin jmeter directory):

<Logger name="org.apache.kafka.clients.producer" level="trace" />

With this configuration you will see new tace lines related to the KafkaProducer and Sender in the Log Viewer window like this:

TRACE o.a.k.c.p.KafkaProducer: [Producer clientId=] Waking up the sender since topic test_topic partition 0 is either full or getting a new batch
TRACE o.a.k.c.p.i.Sender: [Producer clientId=] Nodes with data ready to send: [localhost:29092 (id: 1001 rack: null)]
TRACE o.a.k.c.p.i.Sender: [Producer clientId=] Sent produce request to 1001: (type=ProduceRequest, acks=1, timeout=30000, partitionRecords=([PartitionProduceData(index=0, records=MemoryRecords(size=127, buffer=java.nio.HeapByteBuffer[pos=0 lim=127 cap=127]))]), transactionalId=''
TRACE o.a.k.c.p.i.Sender: [Producer clientId=] Received produce response from node 1001 with correlation id 3
TRACE o.a.k.c.p.i.ProducerBatch: Successfully produced messages to test_topic-0 with base offset 2.

from kloadgen.

@ChameleonTartu have you tried this solution? Do you need anything else from this issue?

from kloadgen.