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