Я ищу способ получения каждой записи об ошибках в обработчике массовых ошибок kafka вместо получения всех записей об успехах и сбоях в обработчике. Есть ли способ сделать это?
Я использую пружинный ботинок с кафкой
public class ErrorHandler implements BatchErrorHandler{
@Override
public void handle(Exception thrownException, ConsumerRecords<?, ?> data) {
data.forEach(k->{
myHandle(k);
});
}
}