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