| 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 |