[BEAM-13653] Improved handling of topicArn in SnsIO.write

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.37.0
• Component/s: io-java-aws
• Labels: aws aws-sdk-v2
• Assignee: Moritz Mack
• Reporter: Moritz Mack
• Created: 13/Jan/22 09:42
• Updated: 24/Jan/22 14:54
• Resolved: 24/Jan/22 14:54

Description

Usage of SnsIO.write is rather unintuitive at the moment.

topicArn is a required configuration and during expansion the existence of the topic is validated.

However, the user also has to provide a function to build an SNS publish request. The topicArn for that publish request has to be set as well, but can be different from the one configured and validated in the writer. 

This is confusing and makes any validation pointless.

Also, when validating the SNS client instance is not closed.

Issue Links

• supercedes: BEAM-13191 Minor fixes to handling AWS clients in SnsIO
• links to: GitHub Pull Request #16503
• links to: GitHub Pull Request #16503