[BEAM-12539] Python Kafka IO: allow to specify command line arguments for default expansion service

• Type: Improvement
• Status: Resolved
• Priority: P3
• Resolution: Not A Problem
• Affects Version/s: 2.31.0
• Fix Version/s: Missing
• Component/s: sdk-py-core
• Assignee: Jan Lukavský
• Reporter: Jan Lukavský
• Created: 25/Jun/21 14:44
• Updated: 13/Jan/22 21:48
• Resolved: 12/Jan/22 08:23

Description

In order to be able to run ExpansionService with specific command line arguments we need to be able to specify these arguments when creating read or write transform.

Issue Links

• links to: GitHub Pull Request #15099