Kafka エラー クラス
一部のデータは、Kafka で使用できなくなったために失われた可能性があります。 Kafka によってデータが期限切れになったか、トピックが トピックが処理されました。このような場合にストリーミング クエリが失敗しないようにするには、ソース オプション failOnDataLoss を false に設定します。理由：
ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO
0 ではなく <startOffset> から始まるパーティション <topicPartition>を追加しました。
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>’ このクエリで設定されている場合は、
このオプションを設定することはお勧めしません。 このオプションは、複数の並列
同じグループ ID を使用するクエリまたはソースは、一部であるため、互いに干渉します
同じコンシューマ グループの。 再起動されたクエリは、
同じグループ ID を持つ前の実行。 ユーザーは、グループ ID ごとに 1 つのクエリのみを持つ必要があります。
および/またはオプション 'Kafka.session.timeout.ms' を設定します。 非常に小さくなるように、 Kafka
前のクエリのコンシューマーは、Kafka グループコーディネーターによって dead とマークされます。
再起動したクエリの実行が開始されます。
PARTITION_OFFSET_CHANGED
パーティション <topicPartition> オフセットが <prevOffset> から <newOffset>に変更されました。
START_OFFSET_RESET
<topicPartition> の開始オフセットは <offset> でしたが、コンシューマは にリセット<fetchedOffset>。