[KAFKA-6279] Connect metrics do not get cleaned up for a source connector that doesn't stop properly

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Duplicate
• Affects Version/s: 1.0.0
• Component/s: connect
• Assignee: Randall Hauch
• Reporter: Randall Hauch
• Created: 28/Nov/17 17:51
• Updated: 29/Nov/17 00:06
• Resolved: 29/Nov/17 00:06

Description

Connect will call stop() on a source task to signal that it should "_stop trying to poll for new data
and interrupt any outstanding poll() requests_" (see the JavaDoc for this method).

Unfortunately, not all connectors properly adhere to this expectation. Since the metrics for the source task are cleaned up only when the worker source task's thread completes, a task whose poll() method blocks forever will current prevent its thread from completing. So, we need to change how the metrics are cleaned up to ensure this always happens.

Issue Links

• duplicates: KAFKA-6252 A metric named 'XX' already exists, can't register another one.