OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
partitionId=Long.toString(((MessageIdImpl)message.getMessageId()).getPartitionIndex());partitionId=messageId.getPartitionIndex();Long.toString(((MessageIdImpl)message.getMessageId()).getPartitionIndex())messageId.getPartitionIndex()pulsarea6eae7d22e94fd2a998813ec9b2af42d9035fc0org.apache.pulsar.functions.source.PulsarSource
_194
_294
_1partitionId
_2partitionId
xyzLong.toString(((MessageIdImpl)message.getMessageId()).getPartitionIndex())
  • java.lang.Long
xyzmessageId.getPartitionIndex()
AssignedToFalse