Implement Pulsar Producer Bridge, which supports publishing messages to Pulsar from MQTT topics.