Sdílet prostřednictvím


KAFKA_DATA_LOSS třída chyb

SQLSTATE: 22000

Některá data můžou být ztracena, protože už nejsou k dispozici v systému Kafka; Buď byla data zastaralá platformou Kafka, nebo se téma mohlo odstranit dříve, než se všechna data v tématu zpracovala. Pokud nechcete, aby dotaz streamování v takových případech selhal, nastavte možnost zdroje failOnDataLoss na false. Důvod:

ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO

Přidání oddílu <topicPartition> začíná od <startOffset> místo 0.

COULD_NOT_READ_OFFSET_RANGE

Nelze číst záznamy v posunu [<startOffset>, <endOffset>) pro oddíl tématu. <topicPartition>

se skupinou <groupId>příjemců .

INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS

Nelze najít počáteční posuny <partitions>oddílů . Je možné, že byly odstraněny.

PARTITIONS_DELETED

Oddíly byly odstraněny <partitions> .

PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRESENT

Oddíly byly odstraněny <partitions> .

Možnost Kafka Kafka<groupIdConfig> byl nastaven na tento dotaz, je

tuto možnost nedoporučujeme nastavit. Tato možnost je nebezpečná, protože více souběžných

dotazy nebo zdroje používající stejné ID skupiny vzájemně kolidují, protože jsou součástí

stejné skupiny příjemců. Restartování dotazů může také mít vliv na

předchozí spuštění se stejným ID skupiny. Uživatel by měl mít pouze jeden dotaz na ID skupiny.

a/nebo nastavte možnost "kafka.session.timeout.ms" na velmi malou, aby kafka

uživatele z předchozího dotazu označí jako mrtvého koordinátora skupiny Kafka před

Spustí se restartovaný dotaz.

PARTITION_OFFSET_CHANGED

Posun oddílu <topicPartition> byl změněn z <prevOffset> na <newOffset>.

START_OFFSET_RESET

Počáteční posun pro <topicPartition> byl <offset> , ale příjemce se resetoval na <fetchedOffset>.