question: the current offset in the partition . this refers to the offset last element that we retrieved and emitted successfully . it is the offset that should be stored in a checkpoint . concode_field_sep KafkaTopicPartition partition concode_elem_sep KPH kafkaPartitionHandle concode_elem_sep long offset concode_elem_sep long committedOffset concode_elem_sep long OFFSET_NOT_SET concode_field_sep boolean isOffsetDefined concode_elem_sep int getPartition concode_elem_sep long getCommittedOffset concode_elem_sep KPH getKafkaPartitionHandle concode_elem_sep void setOffset concode_elem_sep String toString concode_elem_sep String getTopic concode_elem_sep void setCommittedOffset concode_elem_sep KafkaTopicPartition getKafkaTopicPartition
target: long function ( ) { return offset ; }