[KAFKA-6589] Extract Heartbeat thread from Abstract Coordinator for testability purposes

• Type: Improvement
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: consumer
• Assignee: Sandor Murakozi
• Reporter: Guozhang Wang
• Created: 24/Feb/18 01:14
• Updated: 05/Mar/18 15:04

Description

Today we do not have an easy way to instrument the heartbeat thread in our unit test, e.g. to inject a GC or make it crash etc since it is a private class inside AbstractCoordinator.

It is better to extract this class out and also enabling AbstractCoordinator to take a heartbeat-thread interface that can be mocked for test utils.

Issue Links

• links to: GitHub Pull Request #4647