KAFKA_DATA_LOSS エラー クラス

  • [アーティクル]

SQLSTATE: 22000

一部のデータが、Kafka で使用できなくなったために失われた可能性があります。Kafka によってデータが期限切れとされたか、トピック内のすべてのデータが処理される前にそのトピックが削除された可能性がありす。 そのような場合にストリーミング クエリを失敗させたくない場合は、ソース オプション failOnDataLoss を false に設定してください。 理由:

ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO

追加されたパーティション <topicPartition> が、0 ではなく <startOffset> から開始されています。

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 ごとに 1 回のみにし、

また、オプション ‘kafka.session.timeout.ms’ を非常に小さく設定して、

前のクエリの Kafka コンシューマーが Kafka グループ コーディネーターによって停止状態とマークされてから

再起動されたクエリの実行が開始されるようにする必要があります。

PARTITION_OFFSET_CHANGED

パーティション <topicPartition> のオフセットが <prevOffset> から <newOffset> に変更されました。

START_OFFSET_RESET

<topicPartition> の開始オフセットは <offset> でしたが、コンシューマーが <fetchedOffset> にリセットしました。