[KAFKA-13728] PushHttpMetricsReporter no longer pushes metrics when network failure is recovered.

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 3.1.0
• Fix Version/s: 3.2.0
• Component/s: tools
• Assignee: Unassigned
• Reporter: XiaoyiPeng
• Created: 11/Mar/22 02:00
• Updated: 21/Mar/22 17:32
• Resolved: 21/Mar/22 17:32

Description

The class PushHttpMetricsReporter no longer pushes metrics when network failure is recovered.

I debugged the code and found the problem here :
https://github.com/apache/kafka/blob/dc36dedd28ff384218b669de13993646483db966/tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java#L214-L221

 

When we submit a task to the ScheduledThreadPoolExecutor that needs to be executed periodically, if the task throws an exception and is not swallowed, the task will no longer be scheduled to execute.

Issue Links

• links to: GitHub Pull Request #11879