RecordInfo is…FIXME
RecordInfo
node
ProcessorNode node()
node…FIXME
queue
RecordQueue queue()
queue…FIXME
partition
TopicPartition partition()
partition…FIXME