[GOBBLIN-945] Refactor Kafka extractor statistics tracking to allow code reuse across both batch and streaming execution modes

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.15.0
• Fix Version/s: 0.15.0
• Component/s: gobblin-kafka
• Assignee: Shirshanka Das
• Reporter: Sudarshan Vasudevan
• Created: 05/Nov/19 17:29
• Updated: 21/Nov/19 23:31
• Resolved: 08/Nov/19 00:04

Description

Current implementation of kafka extractor stats tracking is deeply integrated with the batch implementation of KafkaExtractor preventing it from being used in streaming Kafka extractor implementations. In addition to code reuse, the refactoring allows for writing unit tests for statistics tracker. 

Issue Links

• links to: GitHub Pull Request #2795