某些数据可能已丢失，因为它们在 Kafka 中不再可用;数据已由 Kafka 过期，或者该主题可能在处理该主题中的所有数据之前被删除。 如果不希望流式查询在这种情况下失败，请将源选项 failOnDataLoss 设置为 false。 原因：
添加的分区未从偏移量零开始
添加了分区 <topicPartition> 从 <startOffset> 开始，而不是从 0 开始。
无法读取偏移范围
无法读取以下使用者组的主题分区 <startOffset> 偏移量 [<endOffset>,<topicPartition>）中的记录：
<groupId>。
INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS
找不到分区 <partitions>的初始偏移量。 它们可能已被删除。
分区已删除
已删除 <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>。
起始偏移重置
<topicPartition> 的起始偏移量为 <offset> 但使用者重置为 <fetchedOffset>。