KAFKA_DATA_LOSS錯誤類別
有些數據可能已經遺失,因為它們無法再在 Kafka 中使用;數據已由 Kafka 淘汰,或主題可能已在處理主題中的所有數據之前刪除。 如果您不希望串流查詢在這類情況下失敗,請將source選項failOnDataLoss設定為 false。 原因:
ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO
新增的數據分割 <topicPartition>
會從 <startOffset>
開始,而不是 0。
COULD_NOT_READ_OFFSET_RANGE
無法讀取位移 [<startOffset>
, <endOffset>
] 中主題分割的記錄 <topicPartition>
使用取用者群組 <groupId>
。
INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS
找不到數據分割 <partitions>
的初始位移。 它們可能已刪除。
PARTITIONS_DELETED
已刪除資料 <partitions>
分割。
PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRESENT
已刪除資料 <partitions>
分割。
Kafka 選項 'kafka.<groupIdConfig>
' 已在此查詢上設定,它是
不建議設定此選項。 此選項不安全,因為有多個並行
使用相同群組標識碼的查詢或來源會干擾彼此,因為它們是一部分
相同取用者群組的 。 重新啟動的查詢也可能受到干擾
上一次執行具有相同的群組標識碼。使用者每個群組標識碼應該只有一個查詢,
和/或將選項 'kafka.session.timeout.ms' 設定為非常小,讓 Kafka
先前查詢的取用者在 之前,會由 Kafka 群組協調器標示為無效
重新啟動的查詢會開始執行。
PARTITION_OFFSET_CHANGED
分割 <topicPartition>
區位移已從 <prevOffset>
變更為 <newOffset>
。
START_OFFSET_RESET
的起始位移 <topicPartition>
為 <offset>
,但取用者重設為 <fetchedOffset>
。