How to write load test for kafka consumer java application?

I have written a kafka consumer application using spring boot. This application consumes messages from kafka, processes it and stores back to another topic of kafka. Now, I want to write load test for the this consumer application. This test should tell me the performance of my consumer application like how much time it is taking to process messages under certain load. Can anyone suggests solutions strategy using integration test / jmeter