Как написать тест производительности для потребительского Java-приложения Kafka?

Question

Я новичок в кафке.Я написал потребительское приложение kafka с использованием весенней загрузки.Это приложение потребляет сообщения от kafka, обрабатывает его и сохраняет в БД.

Теперь я хочу написать тест производительности для этого потребительского приложения.Этот тест должен показать мне производительность моего потребительского приложения, например, сколько времени занимает обработка сообщений при определенной нагрузке.

Я писал тесты производительности ранее, используя Gatling, где у нас есть конечная точка.Но в этом приложении у меня нет конечной точки отдыха.Так что, если я узнаю, как делать тесты производительности для этого приложения или любые указатели будут оценены.

Answer 1

Вы можете использовать скрипт kafka-consumer-perf-test.sh, поставляемый с Kafka.Вы можете указать количество сообщений для чтения, количество потоков обработки и любую из обычных пользовательских конфигураций .Инструмент выведет объем потребляемых данных и пропускную способность среди других показателей.

Answer 2

Вам в основном нужно отправлять сообщения в очередь Kafka и измерять, насколько быстро они обрабатываются вашим приложением, подойдет любой инструмент, подходящий для этого.

1. Например, kafka-console-producer script поставляется с каждым дистрибутивом kafka.

2. Если вы хорошо разбираетесь в Gatling, вы можете использовать плагин Gatling-Kafka .

3. Существует также Pepper-Box - Kafka Load Generator плагин для Apache JMeter , так что вам не придется писать ни одной строки кода.Проверьте Apache Kafka - Как загрузить тест с JMeter статью для более подробной информации, если это необходимо.