共用方式為

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>。