Enum KafkaStartFromConfig

pub enum KafkaStartFromConfig {
    Earliest,
    Latest,
    Offsets(Vec<i64>),
}

Where to begin reading a Kafka topic.

JSON schema

{
 "description": "Where to begin reading a Kafka topic.",
 "oneOf": [
   {
     "description": "Start from the beginning of the topic.",
     "type": "string",
     "enum": [
       "earliest"
     ]
   },
   {
     "description": "Start from the current end of the topic.\n\nThis will only read any data that is added to the topic after the\nconnector initializes.",
     "type": "string",
     "enum": [
       "latest"
     ]
   },
   {
     "type": "object",
     "required": [
       "offsets"
     ],
     "properties": {
       "offsets": {
         "description": "Start from particular offsets in the topic.\n\nThe number of offsets must match the number of partitions in the topic.",
         "type": "array",
         "items": {
           "type": "integer",
           "format": "int64"
         }
       }
     }
   }
 ]
}

Variants

Earliest

Start from the beginning of the topic.

Latest

Start from the current end of the topic.

This will only read any data that is added to the topic after the connector initializes.

Offsets(Vec<i64>)

Trait Implementations

impl Clone for KafkaStartFromConfig

fn clone(&self) -> KafkaStartFromConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KafkaStartFromConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for KafkaStartFromConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<&KafkaStartFromConfig> for KafkaStartFromConfig

fn from(value: &KafkaStartFromConfig) -> Self

Converts to this type from the input type.

impl From<Vec<i64>> for KafkaStartFromConfig

fn from(value: Vec<i64>) -> Self

Converts to this type from the input type.

impl Serialize for KafkaStartFromConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.