yes because a message can have a any destination topic. At the time of processing, we may or maybe not have already created a producer for that topic. We cache producers, so that we don't create a producer for each message and try to reuse existing ones. This is basically the same logic for MultiConsumerProducer used for effectively once where we have to have separate producers for each partition
[ Full content available at: https://github.com/apache/incubator-pulsar/pull/2605 ] This message was relayed via gitbox.apache.org for [email protected]
