Classe di errore KAFKA_DATA_LOSS
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. Per evitare che la query di streaming fallisca in questi casi, impostare l'opzione di origine failOnDataLoss su false. Ragione:
LA_PARTIZIONE_AGGIUNTA_NON_INIZIA_DALL_OFFSET_ZERO
La partizione aggiunta <topicPartition> inizia da <startOffset> anziché da 0.
IMPOSSIBILE_LEGGERE_L'INTERVALLO_DI_OFFSET
Impossibile leggere i record in offset [<startOffset>, <endOffset>) per la partizione dell'argomento <topicPartition>
con il gruppo di consumatori <groupId>.
OFFSET_INIZIALE_NON_TROVATO_PER_PARTIZIONI
Impossibile trovare gli offset iniziali per le partizioni <partitions>. Potrebbero essere stati eliminati.
PARTIZIONI_ELIMINATE
Le partizioni <partitions> sono state eliminate.
PARTIZIONI_ELIMINATE_E_CONFIGURAZIONE_ID_GRUPPO_PRESENTE
Le partizioni <partitions> sono state eliminate.
Opzione Kafka “kafka.<groupIdConfig>” è stato impostato su questa query; è stato definito come
non è consigliabile impostare questa opzione. Questa opzione non è sicura da usare poiché ci sono più processi simultanei.
Le query o le origini che usano lo stesso identificativo di gruppo interferiscono tra loro poiché fanno parte
dello stesso gruppo di consumatori. Le query riavviate possono anche subire interferenze da parte di
esecuzione precedente con lo stesso ID di gruppo. L'utente deve avere una sola query per ID di gruppo,
e/o impostare l'opzione 'kafka.session.timeout.ms' affinché sia molto piccola così che Kafka
I consumatori della query precedente sono contrassegnati come inattivi dal coordinatore del gruppo Kafka prima del
la query riavviata inizia a funzionare.
OFFSET_PARTIZIONE_MODIFICATO
L'offset <topicPartition> della partizione è stato modificato da <prevOffset> a <newOffset>.
reset del punto di partenza dell'offset
L'offset iniziale per <topicPartition> è stato <offset>, ma il consumer viene reimpostato su <fetchedOffset>.