KAFKA_DATA_LOSS hibaosztály

SQLSTATE: 22000

Egyes adatok elveszhettek, mert már nem érhetők el a Kafkában; vagy az adatokat a Kafka kiöregedett, vagy a témakört törölték a témakör összes adatának feldolgozása előtt. Ha nem szeretné, hogy a streamelési lekérdezés ilyen esetekben meghiúsuljon, állítsa a failOnDataLoss forrásbeállítást hamisra. Ok:

ADDED_PARTITION_DOES_NOT_START_FROM_OFF Standard kiadás T_ZERO

A hozzáadott partíció <topicPartition> a 0 helyett kezdődik <startOffset> .

COULD_NOT_READ_OFF Standard kiadás T_RANGE

A témakörpartíció rekordjai nem olvashatók eltolásban [<startOffset>, <endOffset>) <topicPartition>

fogyasztói csoporttal <groupId>.

INITIAL_OFF Standard kiadás T_NOT_FOUND_FOR_PARTITIONS

A partíciók kezdeti eltolásai <partitions>nem találhatók. Lehet, hogy törölték őket.

PARTITIONS_DELETED

A partíciók <partitions> törölve lettek.

PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRE Standard kiadás NT

A partíciók <partitions> törölve lettek.

Kafka lehetőség "kafka.<groupIdConfig>" be van állítva ezen a lekérdezésen,

nem ajánlott ezt a beállítást beállítani. Ez a beállítás nem biztonságos, mivel több egyidejű

az azonos csoportazonosítót használó lekérdezések vagy források zavarják egymást, mivel azok részei

egyazon fogyasztói csoporthoz tartozó. Az újraindult lekérdezések is zavarhatják a

előző futtatás ugyanazzal a csoportazonosítóval. A felhasználónak csoportazonosítónként csak egy lekérdezésnek kell lennie,

és/vagy állítsa a "kafka.session.timeout.ms" beállítást nagyon kicsire, hogy a Kafka

az előző lekérdezés felhasználóit a Kafka-csoport koordinátora halottként jelöli meg a

az újraindult lekérdezés elindul.

PARTITION_OFF Standard kiadás T_CHANGED

A partíció <topicPartition> eltolása a következőre <prevOffset><newOffset>módosult: .

START_OFF Standard kiadás T_RE Standard kiadás T

A kezdő eltolás a következő volt<offset>, <topicPartition> de a fogyasztó visszaállt a következőre<fetchedOffset>: .