KAFKA_DATA_LOSS třída chyb
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>
.