KAFKA_DATA_LOSS, classe d’erreur
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>
.