Incorrect logging of exception in Kafka Connector

[mandy-chessell]

Issue #4952 describes a situation where an exception is coming from Apache Kafka that is causing the connector to end abnormally and the exception is being logging through SLF4J rather tthan the audit log.

[mandy-chessell]

This is the offending code in KafkaOpenMetadataEventProducer:

            catch (Throwable   error)
            {
                log.error("Bad exception from sending events " + error.getMessage());

                if( isExceptionRetryable(error) ) {
                    this.recoverAfterError();
                }
                else {

                    /* This is an unrecoverable error so clean up and shutdown*/
                    break;
                }
            }

[planetf1]

@wbittles Do you want to look at this?

[wbittles]

After some investigation I changed the proposed fix for this issue and created a new PR.
The above code is only executed when exceptions have been encountered and audit log entries should have already been called.
I believe I've traced the offending piece of code and added the missing audit logs entries.

[github-actions]

This issue has been automatically marked as stale because it has not had recent activity. It will be closed in 20 days if no further activity occurs. Thank you for your contributions.

[planetf1]

Closing as this looks to be complete