OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
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_BYTESMath.min(maxBatchSize,MAX_MESSAGE_BATCH_SIZE_BYTES)pulsar3615e25f91aed95e7f5896449f6d72085489ef65org.apache.pulsar.client.impl.BatchMessageContainer
_162
_261
_1MAX_MESSAGE_BATCH_SIZE_BYTES
_2MAX_MESSAGE_BATCH_SIZE_BYTES
TCIVarMAX_MESSAGE_BATCH_SIZE_BYTES
  • java.lang.Math
TCIVarMAX_MESSAGE_BATCH_SIZE_BYTES
UsesFalse