Key Features

• Introduced a new helper function isTransientNetworkError, which evaluates error messages to identify transient network issues. This enhancement improves the robustness of error handling in the Kafka consumer.

Bug Fixes

• Updated logging behavior for transient network errors in the Kafka consumer. These errors are now logged as Info instead of Error, minimizing the occurrence of false-positive alerts related to network EOFs and closed connections.

Technical Improvements

• Refactored the consumeExtraction and consumeSync methods to incorporate checks for transient network errors prior to logging. This change streamlines the logging process and enhances clarity in error reporting.
• Added 22 lines of new code to implement the updated logging logic and the new helper function, while removing 2 lines of outdated error logging to maintain code quality and efficiency.