Hello everyone, Does anyone know if it is possible to provide a topic name embedded in a PCollection object to kafkaIO while writing ?
We have a use case where we have a team specific kafka topic for eg teamA_topicname, teamB_topicname. >From beam, we create PCollection<KV<Teamname, data>> and we need to send this data to kafka over aforementioned team specific topics. Is it possible to provide topic names dynamically to kafkaIO.write().withTopic() from Key present in KV PCollection ? Thanks and regards Mohil
