batchedMessageMetadataAndPayload=PooledByteBufAllocator.DEFAULT.buffer((int)MAX_MESSAGE_BATCH_SIZE_BYTES,(int)(PulsarDecoder.MaxMessageSize)); | batchedMessageMetadataAndPayload=PooledByteBufAllocator.DEFAULT.buffer(Math.min(maxBatchSize,MAX_MESSAGE_BATCH_SIZE_BYTES),PulsarDecoder.MaxMessageSize); | (int)MAX_MESSAGE_BATCH_SIZE_BYTES | Math.min(maxBatchSize,MAX_MESSAGE_BATCH_SIZE_BYTES) | pulsar | 3615e25f91aed95e7f5896449f6d72085489ef65 | org.apache.pulsar.client.impl.BatchMessageContainer | | _1 | MAX_MESSAGE_BATCH_SIZE_BYTES |
---|
_2 | MAX_MESSAGE_BATCH_SIZE_BYTES |
---|
| TCIVar | MAX_MESSAGE_BATCH_SIZE_BYTES |
---|
| | TCIVar | MAX_MESSAGE_BATCH_SIZE_BYTES |
---|
| Uses | False |