pyflink.datastream.connectors.kafka.KafkaTopicSelector# class KafkaTopicSelector[source]# Select topic for an incoming record New in version 1.16.0. Methods apply(data)