KAFKA_DATA_LOSS 错误类

  • 项目

SQLSTATE：22000

有些数据可能已经丢失，因为它们在 Kafka 中不再可用；数据已被 Kafka 设为过期，或者主题可能在其中的所有数据处理完毕之前已被删除。 如果不希望流式查询在这种情况下失败，请将源选项 failOnDataLoss 设置为 false。 原因：

ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO

添加的分区 <topicPartition> 从 <startOffset>（而不是 0）开始。

COULD_NOT_READ_OFFSET_RANGE

无法使用以下使用者组为主题分区 <topicPartition> 读取偏移量 [<startOffset>，<endOffset>) 中的记录：

<groupId>。

INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS

找不到分区 <partitions> 的初始偏移量。 它们可能已被删除。

PARTITIONS_DELETED

分区 <partitions> 已被删除。

PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRESENT

分区 <partitions> 已被删除。

Kafka 选项“kafka.<groupIdConfig>” 已在此查询上设置，

不建议设置此选项。 使用此选项不安全，因为

使用相同组 ID 的多个并发查询或源将相互干扰，因为它们

属于同一使用者组。 重启的查询也可能受到

具有相同组 ID 的前一次运行的干扰。用户的每个组 ID 只能有一个查询，

和/或将选项“kafka.session.timeout.ms”设置为非常小得值，以便 Kafka

以便在重启的查询开始运行之前，Kafka 组协调器将前一个查询中的 Kafka 使用者

标记为不活动。

PARTITION_OFFSET_CHANGED

分区 <topicPartition> 偏移量已从 <prevOffset> 更改为 <newOffset>。

START_OFFSET_RESET

<topicPartition> 的起始偏移量为 <offset> 但使用者重置为 <fetchedOffset>。