def exec(execs: Execs[_]*): B = exec(execs.toIterable)

похоже это то что нужно, спс

Всем привет. Такая ситуация. Перед отправкой запроса надо вычитать сообщение из Кафки.
Написал реализацию на груви, которая вычитывает сообщение, но получается у меня куча времени уходит на постоянное подключение, отключение, подписку и ТД.
1) Есть ли в JMeter возможность в переменную добавить синглтон груви объект, который будет сохранять подключение?
2) Кто нибудь сталкивался впринципе с вычиткой из Кафки в Jmeter? Может у кого статейка есть какая?

А что мешает сохранить переменную с коннектом в проперти и использовать в разных тредах или итерациях?

Уже так и сделал

Привет, Миша.

Как понял, ты хочешь, чтобы в строке 179 передавались ещё и заголовки
https://github.com/GSLabDev/pepper-box/blob/master/src/main/java/com/gslab/pepper/sampler/PepperBoxKafkaSampler.java#L179

Сейчас там используется простой конструктор

ProducerRecord​(java.lang.String topic, K key, V value)

Значит, чтобы в записи появились заголовки можно просто добавить заголовок перед отправкой.

Перед строкой 179 сделай так:

String kafkaHeader = JMeterContextService.getContext().getVariables().get("kafkaHeader");
if(kafkaHeader != null) {
  producerRecord.headers().add("HEADER_KEY", kafkaHeader.getBytes())
}

Где-то в коде теста определи переменную с именем kafkaHeader. Например, через User Parameters
https://jmeter.apache.org/usermanual/component_reference.html#User_Parameters

Тут показан пример хардкода, когда задаётся ровно один заголовок, имя которого HEADER_KEY.
Но это так, чтобы идею проверить.
Если сработает, сделать большее количество заголовков можно по аналогии. Или можно сделать более удобный метод. Передавать в sampler целую хеш-таблицу заголовков.

есть еще плагины для очередей

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

подскажите как можно еще проверить ?

Kafka -> Service -> DB

в кафку стреляешь и всё

какие пробелмы там ещё могут быть?

так а как узнать пропускную способность сервиса?

как ее замерять?

заслать 100500 в кафку и смотреть как скоро он справится?

Привет.
Был подобный опыт
Больше всего тут помогла телеметрия

Слали на Кафку 100500 и смотрели:
- метрики Кафки (софт и хард)
- сколько по времени и количеству занимает обработка ивентов сервисом который идет за Кафкой

Может есть и практики лучше, но как быстрая реализация помогло
Сами метрики ДевОпсы с Девами настраивали.

Спасибо за совет, а чем в кафку стреляли?

JMeter + Код в самом JMeter

нужно смотреть разницу между записью и вычитыванием, если вычитка не успевает - значит сообщения копятся

Так и делаем