Получить имя темы, раздел и смещение в случае обработчиков ошибок контейнера

Question

Я получаю исключение десериализации при использовании данных из темы Кафки.Я хочу установить смещение на текущий +1.У меня есть обработчик ошибок на уровне container , который принимает исключение, запись потребителя и объекты потребителя в аргументе.В сообщении об исключении я вижу тему, раздел и смещение.Но потребительская запись равна нулю .Как получить тему, раздел и смещение?

Пожалуйста, помогите.

Answer 1

Ошибка возникает до создания ConsumerRecord.

Начиная с версии 2.2, вы можете настроить ErrorHandlingDeserializer2 для переноса реального десериализатора;Затем контейнер вызывает обработчик ошибок с DeserializationException, и вы получите ConsumerRecord со значением null.

Исключение имеет исходный byte[] в свойстве data.