sngular
[Issue]: Consumer does not show consumed messages in JMeter
What happened?
Relevant discussion: https://github.com/sngular/kloadgen/discussions/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?
- [X] I have added a JMX testplan
Have you added your Schema or a replica?
- [X] I have added the Schema
