public <T> org.apache.pulsar.client.api.TypedMessageBuilder<T> createMessageBuilder(String topic,
Create a TypedMessageBuilder which could be sent to Pulsar directly. First, we would create a
topic-related producer or use a cached instead. Then we would try to find a topic-related
transaction. We would generate a transaction instance if there is no transaction. Finally, we
create the message builder and put the element into it.