During error handling, records in retry are throwing KafkaException after seeking that causes the exception to get logged which maybe misleading. It seems to indicate that the error handling process itself thew the exception, while the exception was thrown in order to prevent accidental committing of a not-yet recovered record. Change this exception during seeks in retry while handling error from KafkaException to a new framework-only used exception - RecordInRetryException that simply logs the message at INFO level.
Fixes: #3409
KafkaExceptionafter seeking that causes the exception to get logged which maybe misleading. It seems to indicate that the error handling process itself thew the exception, while the exception was thrown in order to prevent accidental committing of a not-yet recovered record. Change this exception during seeks in retry while handling error fromKafkaExceptionto a new framework-only used exception -RecordInRetryExceptionthat simply logs the message at INFO level.