[HUDI-4624] Make sure all DeltaStreamer Sources are Closeable

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 0.12.2
• Component/s: deltastreamer
• Labels: pull-request-available
• Story Points: 3
• Assignee: Jonathan Vexler
• Reporter: Alexey Kudinkin
• Created: 15/Aug/22 20:07
• Updated: 08/Feb/23 02:15
• Resolved: 03/Nov/22 15:46

Description

Currently, many of the sources acquire resources (creating Kafka/Pulsar/SQS/etc clients) but are not releasing them properly, since they don't implement `Closeable` interface proeprly.

We need to rectify that by making sure that any DS Source that acquires some resource, releases it properly in `close`.

Issue Links

• links to: GitHub Pull Request #7086