Teilen über


KAFKA_DATA_LOSS Fehlerzustand

SQLSTATE: 22000

Einige Daten sind möglicherweise verloren gegangen, weil sie in Kafka nicht mehr verfügbar sind; entweder wurden die Daten von Kafka ausgelöscht, oder das Thema wurde möglicherweise gelöscht, bevor alle Daten im Thema verarbeitet wurden. Wenn Ihre Streaming-Abfrage in solchen Fällen nicht fehlschlagen soll, legen Sie die Quelloption "failOnDataLoss" auf "false" fest. Grund:

HINZUGEFÜGTE_PARTITION_BEGINNT_NICHT_BEI_OFFSET_NULL

Die hinzugefügte Partition <topicPartition> beginnt bei <startOffset> anstatt bei 0.

KANN_OFFSETBEREICH_NICHT_LESEN

Konnte Datensätze im Offset [<startOffset>, <endOffset>) für Themenpartition <topicPartition> nicht lesen.

mit Verbrauchergruppe <groupId>.

INITIAL_OFFSET_NICHT_GEFUNDEN_FÜR_PARTITIONEN

Anfängliche Offsets für Partitionen <partitions> wurden nicht gefunden. Sie wurden möglicherweise gelöscht.

PARTITIONEN_GELÖSCHT

Partitionen <partitions> wurden gelöscht.

PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRESENT

Partitionen <partitions> wurden gelöscht.

Kafka-Option 'kafka.<groupIdConfig>' wurde für diese Abfrage festgelegt, es ist

nicht empfohlen, diese Option festzulegen. Diese Option ist unsicher zu verwenden, da mehrere gleichzeitige Zugriffe stattfinden können.

Abfragen oder Quellen, die dieselbe Gruppen-ID verwenden, stören sich gegenseitig, da sie Teil sind

derselben Verbrauchergruppe. Neu gestartete Abfragen können auch Störungen von der Umgebung erleiden.

Vorherige Ausführung mit derselben Gruppen-ID. Der Benutzer sollte nur eine Abfrage pro Gruppen-ID haben,

und/oder die Option "kafka.session.timeout.ms" auf einen sehr kleinen Wert einstellen, damit die Kafka

Konsumenten aus der vorherigen Abfrage werden vom Kafka-Gruppenkoordinator als tot markiert, bevor der

Die neu gestartete Abfrage läuft.

PARTITIONSVERSATZ_GEÄNDERT

Der Partitionsoffset <topicPartition> wurde von <prevOffset> auf <newOffset> geändert.

Startversatz zurücksetzen

Der Anfangsoffset für <topicPartition> war <offset>, aber wurde für den Verbraucher auf <fetchedOffset> zurückgesetzt.