Hi all, I have a beam pipeline, which will read from kafka topic via KafkaIO, and based on the message field, add additional field in the message for the destination topic.
I see KakfaIO.write can be used to publish to kafka topics. In KafkaIO.java, it construct the ProducerRecord, and getTopic() determines which topic to publish, and this information is passed when create PTransforms via KafkaIO.write. Any suggestions to dynamically set kafka topic from message field? Thanks a lot! Eleanore
