classe di errore KAFKA_DATA_LOSS

SQLSTATE: 22000

Alcuni dati potrebbero essere stati persi perché non sono più disponibili in Kafka; i dati sono stati obsoleti da Kafka o l'argomento potrebbe essere stato eliminato prima dell'elaborazione di tutti i dati nell'argomento. Se non si vuole che la query di streaming non riesca in questi casi, impostare l'opzione di origine failOnDataLoss su false. Motivo:

ADDED_PARTITION_DOES_NOT_START_FROM_OFF edizione Standard T_ZERO

La partizione <topicPartition> aggiunta inizia da <startOffset> invece di 0.

COULD_NOT_READ_OFF edizione Standard T_RANGE

Impossibile leggere i record in offset [<startOffset>, <endOffset>) per la partizione dell'argomento <topicPartition>

con il gruppo di <groupId>consumer .

INITIAL_OFF edizione Standard T_NOT_FOUND_FOR_PARTITIONS

Impossibile trovare gli offset iniziali per le <partitions>partizioni . Potrebbero essere stati eliminati.

PARTITIONS_DELETED

<partitions> Le partizioni sono state eliminate.

PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRE edizione Standard NT

<partitions> Le partizioni sono state eliminate.

Opzione Kafka 'kafka'.<groupIdConfig> è stato impostato su questa query, è

non consigliato per impostare questa opzione. Questa opzione non è sicura da usare perché più simultanee

query o origini che usano lo stesso ID gruppo interferiscono tra loro mentre fanno parte

dello stesso gruppo di consumer. Le query riavviate possono anche subire interferenze da parte di

esecuzione precedente con lo stesso ID gruppo. L'utente deve avere una sola query per ID gruppo,

e/o impostare l'opzione 'kafka.session.timeout.ms' in modo che sia molto piccola in modo che kafka

i consumer della query precedente sono contrassegnati come non recapitabili dal coordinatore del gruppo Kafka prima del

la query riavviata viene avviata.

PARTITION_OFF edizione Standard T_CHANGED

L'offset della partizione <topicPartition> è stato modificato da <prevOffset> a <newOffset>.

START_OFF edizione Standard T_RE edizione Standard T

Offset iniziale per <topicPartition> è stato <offset> ma il consumer viene reimpostato su <fetchedOffset>.