Partager via


KAFKA_DATA_LOSS, classe d’erreur

SQLSTATE : 22000

Certaines données ont peut-être été perdues, car elles ne sont plus disponibles dans Kafka. Soit les données ont été rendues obsolètes par Kafka, soit la rubrique a peut-être été supprimée avant que toutes les données de la rubrique n’aient été traitées. Si vous ne souhaitez pas que votre requête de diffusion en continu échoue dans de tels cas, définissez l’option source failOnDataLoss sur false. Motif :

ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO

La partition ajoutée <topicPartition> commence à partir de <startOffset> au lieu de 0.

COULD_NOT_READ_OFFSET_RANGE

Nous ne pouvons pas lire les enregistrements dans le décalage [<startOffset>, <endOffset>) pour la partition de rubrique <topicPartition>

avec le groupe de consommateurs <groupId>.

INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS

Nous ne pouvons pas trouver les décalages initiaux pour les partitions <partitions>. Ils ont peut-être été supprimés.

PARTITIONS_DELETED

Les partitions <partitions> ont été supprimées.

PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRESENT

Les partitions <partitions> ont été supprimées.

L’option Kafka « kafka.<groupIdConfig> » a été définie sur cette requête. Il n’est

pas recommandé de définir cette option. Cette option présente un risque pour la sécurité, car plusieurs

requêtes ou sources simultanées utilisant le même ID de groupe et faisant partie du même groupe de consommateurs

interfèrent entre elles. Les requêtes redémarrées peuvent également subir des interférences si

l’exécution précédente a le même ID de groupe. L’utilisateur doit avoir une seule requête par ID de groupe

et/ou définir l’option « kafka.session.timeout.ms » sur une valeur très petite afin que les consommateurs

Kafka de la requête précédente soient marqués comme morts par le coordinateur du groupe Kafka avant que la

requête redémarrée ne commence à s’exécuter.

PARTITION_OFFSET_CHANGED

Le décalage de la partition <topicPartition> est passé de <prevOffset> à <newOffset>.

START_OFFSET_RESET

Le décalage de départ pour <topicPartition> était de <offset>, mais le consommateur l’a réinitialisé à <fetchedOffset>.