共用方式為


KAFKA_DATA_LOSS錯誤類別

SQLSTATE: 22000

有些數據可能已經遺失,因為它們無法再在 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>