通过

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 使用者

标记为“不活动”。

PARTITION_OFFSET_CHANGED

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

START_OFFSET_RESET

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