write to a kafka topic that is set in data

[minaevd]

Hi guys!!

I'm trying to find a way to write to a Kafka topic using KafkaIO.write() But I 
need to be able to get topic name dynamically based on the data received. For 
example, I would like to send data for one tenant to topic "data_feed_1" and 
for another tenant to "topic data_feed_999".
I'm coming from Flink where it's possible via 
KeyedSerializationSchema.getTargetTopic().
Is there anything similar in KafkaIO?

Thanks,
Dmitry