[BEAM-3677] Declare proper exception type in catch block of KafkaExactlyOnceSink#initShardWriter

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: io-java-kafka
• Assignee: Unassigned
• Reporter: Ted Yu
• Created: 09/Feb/18 16:27
• Updated: 03/Jun/22 19:30

Description

      } catch (Exception e) {
        producer.close();
        throw e;

initShardWriter throws IOException. The catch block shouldn't widen the exception type.
If the intention is to properly close producer, we can use try-with-resources.