fn pulsar_producer_routing_policy( routing_mode: Option<PulsarRoutingMode>, ) -> Option<RoutingPolicy>