KAFKA_DATA_LOSS foutstatus

SQLSTATE: 22000

Sommige gegevens zijn mogelijk verloren gegaan omdat ze niet meer beschikbaar zijn in Kafka; de gegevens zijn verouderd door Kafka of het onderwerp is mogelijk verwijderd voordat alle gegevens in het onderwerp zijn verwerkt. Als u niet wilt dat uw streamingquery mislukt in dergelijke gevallen, stelt u de bronoptie failOnDataLoss in op false. Reden:

Toegevoegde partitie start niet vanaf offset nul

De toegevoegde partitie <topicPartition> begint vanaf <startOffset> in plaats van 0.

KON_OFFSETBEREIK_NIET_LEZEN

Kan records niet lezen in offset [<startOffset>, <endOffset>] voor onderwerppartitie <topicPartition>

met consumentengroep <groupId>.

INITIËLE_OFFSET_NIET_GEVONDEN_VOOR_PARTITIES

Kan initiële verschuivingen voor partities <partitions>niet vinden. Ze zijn mogelijk verwijderd.

PARTITIONS_DELETED

Partities <partitions> zijn verwijderd.

VERWIJDERDE_PARTITIES_EN_GROEP_ID_CONFIG_AANWEZIG

Partities <partitions> zijn verwijderd.

Kafka-optie 'kafka.<groupIdConfig>' is ingesteld voor deze query.

wordt niet aanbevolen om deze optie in te stellen. Deze optie is onveilig om te gebruiken vanwege meerdere gelijktijdige processen.

Queries of bronnen die dezelfde groeps-id gebruiken, zullen elkaar verstoren omdat ze deel uitmaken van dezelfde groep.

van dezelfde consumentengroep. Opnieuw gestarte queries kunnen ook last ondervinden van verstoringen door de

vorige uitvoering met dezelfde groeps-id. De gebruiker mag slechts één query per groeps-id hebben,

en/of stel de optie 'kafka.session.timeout.ms' zo in dat deze zeer klein is, zodat Kafka

gebruikers uit de vorige query zijn gemarkeerd als dood door de Kafka-groepscoördinator vóór de

opnieuw gestarte query start met uitvoeren.

PARTITIE_OFFSET_GEWIJZIGD

De partitie-<topicPartition> offset is gewijzigd van <prevOffset> naar <newOffset>.

START_OFFSET_RESET

De startoffset voor <topicPartition> was <offset>, maar de consument werd teruggezet naar <fetchedOffset>.