Найти время пакетной обработки Spring Kafka ⇐ JAVA

[Anonymous]

У меня есть потребитель Kafka со следующими конфигурациями

Код: Выделить всё

enable.auto.commit : true
max.poll.records: 50
auto.commit.interval.ms : 10000

И потребительский метод выглядит следующим образом:

Код: Выделить всё

@KafkaListener(topics = ("my-topic"),groupId = ("groupId"),
containerFactory = "listenerContainerFactory",concurrency = 2 ,autoStartup = "true")
public void myListener(@Payload String message) {
System.out.println("Received Message : " + message);
// do some heavy processing
}

Я знаю, что Spring kafka будет получать 50 сообщений (max.poll.records) одновременно и использовать два потока для обработки сообщений (concurrency = 2).
Теперь мне нужно узнать, сколько времени ушло на выполнение этой партии. Это означает 20 сообщений в двух цепочках.
Где я могу разместить свой регистратор, чтобы получить эту информацию?

Подробнее здесь: https://stackoverflow.com/questions/659 ... ocess-time