Как распознать ошибку записи в kafka обработчике ошибок? - PullRequest
0 голосов
/ 30 июня 2019

Я ищу способ получения каждой записи об ошибках в обработчике массовых ошибок kafka вместо получения всех записей об успехах и сбоях в обработчике. Есть ли способ сделать это?

Я использую пружинный ботинок с кафкой

public class ErrorHandler implements BatchErrorHandler{

        @Override
        public void handle(Exception thrownException, ConsumerRecords<?, ?> data) {
            data.forEach(k->{
                myHandle(k);
            });
        }
 }
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...