| 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 |