Class PartitionConsumptionState.TransientRecord

  • Enclosing class:

    public static class PartitionConsumptionState.TransientRecord
    extends java.lang.Object
    This immutable class holds a association between a key and value and the source offset of the consumed message. The value could be either as received in kafka ConsumerRecord or it could be a write computed value.
    • Constructor Detail

      • TransientRecord

        public TransientRecord​(byte[] value,
                               int valueOffset,
                               int valueLen,
                               int valueSchemaId,
                               int kafkaClusterId,
                               long kafkaConsumedOffset)
    • Method Detail

      • setReplicationMetadataRecord

        public void setReplicationMetadataRecord​(org.apache.avro.generic.GenericRecord replicationMetadataRecord)
      • getReplicationMetadataRecord

        public org.apache.avro.generic.GenericRecord getReplicationMetadataRecord()
      • getValue

        public byte[] getValue()
      • getValueOffset

        public int getValueOffset()
      • getValueLen

        public int getValueLen()
      • getValueSchemaId

        public int getValueSchemaId()