partitionId=Long.toString(messageId.getPartitionIndex()); | partitionId=((MessageIdImpl)message.getMessageId()).getPartitionIndex(); | Long.toString(messageId.getPartitionIndex()) | ((MessageIdImpl)message.getMessageId()).getPartitionIndex() | pulsar | ea6eae7d22e94fd2a998813ec9b2af42d9035fc0 | org.apache.pulsar.functions.source.PulsarSource | | _1 | partitionId |
---|
_2 | partitionId |
---|
| xyz | Long.toString(messageId.getPartitionIndex()) |
---|
| | xyz | ((MessageIdImpl)message.getMessageId()).getPartitionIndex() |
---|
| AssignedTo | False |