How to setup Kafka in Windows | How to Load test Kafka using JMeter

[@mahip2704]

You covered everything, Thanks for your information.

[@littleslawyoutubechannel]

You are welcome

[@pritamdey7531]

Thanks for the video.
I am getting below error while executing from Jmeter:
ERROR c.s.l.LoadGenerator: Exception initializing Load Generator class: co.signal.loadgen.example.TagserveLoadGenerator
java.lang.reflect.InvocationTargetException: null
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:1.8.0_144]
at sun.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source) ~[?:1.8.0_144]
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown Source) ~[?:1.8.0_144]
at java.lang.reflect.Constructor.newInstance(Unknown Source) ~[?:1.8.0_144]
at co.signal.loadgen.LoadGenerator.createGenerator(LoadGenerator.java:67) [kafkameter-0.2.0.jar:?]
at co.signal.loadgen.LoadGenerator.iterationStart(LoadGenerator.java:57) [kafkameter-0.2.0.jar:?]
at org.apache.jmeter.control.GenericController.fireIterationStart(GenericController.java:412) [ApacheJMeter_core.jar:5.6.2]
at org.apache.jmeter.control.GenericController.fireIterEvents(GenericController.java:404) [ApacheJMeter_core.jar:5.6.2]
at org.apache.jmeter.control.GenericController.next(GenericController.java:170) [ApacheJMeter_core.jar:5.6.2]
at org.apache.jmeter.control.LoopController.next(LoopController.java:119) [ApacheJMeter_core.jar:5.6.2]
at org.apache.jmeter.threads.AbstractThreadGroup.next(AbstractThreadGroup.java:109) [ApacheJMeter_core.jar:5.6.2]
at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:266) [ApacheJMeter_core.jar:5.6.2]
at java.lang.Thread.run(Unknown Source) [?:1.8.0_144]
Caused by: java.lang.RuntimeException: Site weights must sum to unity
at co.signal.loadgen.example.TagserveLoadGenerator.parseSiteWeights(TagserveLoadGenerator.java:126) ~[kafkameter-0.2.0.jar:?]
at co.signal.loadgen.example.TagserveLoadGenerator.(TagserveLoadGenerator.java:61) ~[kafkameter-0.2.0.jar:?]
... 13 more
2024-07-25 12:18:42,966 ERROR o.a.j.t.JMeterThread: Test failed!
java.lang.RuntimeException: java.lang.reflect.InvocationTargetException
at com.google.common.base.Throwables.propagate(Throwables.java:160) ~[guava-19.0.0.jar:?]
at co.signal.loadgen.LoadGenerator.createGenerator(LoadGenerator.java:70) ~[kafkameter-0.2.0.jar:?]
at co.signal.loadgen.LoadGenerator.iterationStart(LoadGenerator.java:57) ~[kafkameter-0.2.0.jar:?]
at org.apache.jmeter.control.GenericController.fireIterationStart(GenericController.java:412) ~[ApacheJMeter_core.jar:5.6.2]
at org.apache.jmeter.control.GenericController.fireIterEvents(GenericController.java:404) ~[ApacheJMeter_core.jar:5.6.2]
at org.apache.jmeter.control.GenericController.next(GenericController.java:170) ~[ApacheJMeter_core.jar:5.6.2]
at org.apache.jmeter.control.LoopController.next(LoopController.java:119) ~[ApacheJMeter_core.jar:5.6.2]
at org.apache.jmeter.threads.AbstractThreadGroup.next(AbstractThreadGroup.java:109) ~[ApacheJMeter_core.jar:5.6.2]
at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:266) [ApacheJMeter_core.jar:5.6.2]
at java.lang.Thread.run(Unknown Source) [?:1.8.0_144]
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:1.8.0_144]
at sun.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source) ~[?:1.8.0_144]
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown Source) ~[?:1.8.0_144]
at java.lang.reflect.Constructor.newInstance(Unknown Source) ~[?:1.8.0_144]
at co.signal.loadgen.LoadGenerator.createGenerator(LoadGenerator.java:67) ~[kafkameter-0.2.0.jar:?]
... 8 more
Caused by: java.lang.RuntimeException: Site weights must sum to unity
at co.signal.loadgen.example.TagserveLoadGenerator.parseSiteWeights(TagserveLoadGenerator.java:126) ~[kafkameter-0.2.0.jar:?]
at co.signal.loadgen.example.TagserveLoadGenerator.(TagserveLoadGenerator.java:61) ~[kafkameter-0.2.0.jar:?]
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:1.8.0_144]
at sun.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source) ~[?:1.8.0_144]
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown Source) ~[?:1.8.0_144]
at java.lang.reflect.Constructor.newInstance(Unknown Source) ~[?:1.8.0_144]
at co.signal.loadgen.LoadGenerator.createGenerator(LoadGenerator.java:67) ~[kafkameter-0.2.0.jar:?]
... 8 more
Pls help to understand the error.

[@littleslawyoutubechannel]

Looks like some connection or config issue . Let me check

[@gourabmitra3365]

The response time Jmeter is giving i think it represents only the load times of the message in topic ...how to get how much time actually the message took to get processed from producer-> consumer does kafka have any logging in itself which can show this...personally from JMS perspective load generation tool response time and application service time is entirely different what i have seen ,,please shed some light on this ....also expecting more videos on the monitoring part of kafka and identification of bottlenecks..Thanks

[@littleslawyoutubechannel]

I agree and what you say is a very valid point. I will discuss the answer for your questions in my next video. Thanks for asking . Hope you liked the video.

[@RajeshL-gk9xh]

@@littleslawyoutubechannel Where do we get your git url ??

[@littleslawyoutubechannel]

I will upload it shortly. Thanks for asking ..

[@RajeshL-gk9xh]

@@littleslawyoutubechannel Thanks for your reply , waiting for your upcoming videos

[@littleslawyoutubechannel]

Thanks much ..

[@HOPE98901]

What is Kafka can you please explain in bit easy way not clear it felt like you reading some sentence