return producers.get(partition).send(message); | return producers.get(partition).internalSendAsync(message); | producers.get(partition).send(message) | producers.get(partition).internalSendAsync(message) | pulsar | 0f2f478c1ffc4028d7fd271a1bc523b3342a07af | org.apache.pulsar.client.impl.PartitionedProducerImpl | | _1 | send |
---|
_2 | internalSendAsync |
---|
| v0 | producers.get(partition) |
---|
v1 | message |
---|
| | v0 | producers.get(partition) |
---|
v1 | message |
---|
| Returns | True |