[GOBBLIN-1351] Ensure KafkaStreamingExtractor shutdown is invoked on task shutdown

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 0.16.0
• Fix Version/s: 0.17.0
• Component/s: gobblin-kafka
• Assignee: Shirshanka Das
• Reporter: Sudarshan Vasudevan
• Created: 06/Jan/21 03:26
• Updated: 14/Jun/23 04:13

Description

KafkaStreamingExtractor extends InstrumentedExtractorBase which currently does not invoke the shutdown() method when a task shutdown is requested.