[Issue]: Consumer does not show consumed messages in JMeter

[CROprogrammer]

What happened?

Relevant discussion: #425

I have a case in which I want to send as many messages from Producer to Topic in a short period, and to read messages from that topic in Consumer. I can achive high throughput in Producer and number of messages I've defined are sent, but Consumer that runs parallel to Producer skips a lot of messages from topic or it does not consume them.

How can I achive that my consumer does not skip messages and that it consumes all messages produced in producer?

When I use Constant Timer then Consumer can process message, but then too few messages can be send to Topic in short period of time.

Test plans:
Test.Plans.zip

Schema:
{
"type": "record",
"namespace": "com.example",
"name": "Student",
"fields": [
{ "name": "name", "type": "string" },
{ "name": "age", "type": "int", "default" : -1 }
]
}

KloadGen Version

KLoadGen 5.6.6

Relevant log output

No response

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