Speaker(s):

using pub/subIO writeMessageDynamic() function in a Python pipeline to use dynamic topic destination

Sep-4 16:00-16:25 in Hamina (MP4)
Add to Calendar 09/04/2024 4:00 PM 09/04/2024 4:25 PM America/Los_Angeles AS24: using pub/subIO writeMessageDynamic() function in a Python pipeline to use dynamic topic destination

Enabling dynamic topic destinations using the pub/subIO writeMessageDynamic() function in a Java Dataflow pipeline is an interesting feature, which seems only available in Apache Beam Java SDK. This talk is to showcase a workaround implementation using the pub/subIO writeMessageDynamic() function as an external transform

Hamina (MP4)

Enabling dynamic topic destinations using the pub/subIO writeMessageDynamic() function in a Java Dataflow pipeline is an interesting feature, which seems only available in Apache Beam Java SDK. This talk is to showcase a workaround implementation using the pub/subIO writeMessageDynamic() function as an external transform