KAFKA_DATA_LOSS-Fehlerklasse
Einige Daten sind möglicherweise verloren gegangen, weil sie in Kafka nicht mehr verfügbar sind. Entweder wurden die Daten von Kafka als veraltet markiert, oder das Thema wurde möglicherweise gelöscht, bevor alle Daten im Thema verarbeitet wurden. Wenn Ihre Streamingabfrage in solchen Fällen nicht fehlschlagen soll, legen Sie die Quelloption „failOnDataLoss“ auf „false“ fest. Ursache:
ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO
Die hinzugefügte Partition <topicPartition> beginnt bei <startOffset> anstatt bei 0.
COULD_NOT_READ_OFFSET_RANGE
Die Datensätze im Offset [<startOffset>, <endOffset>) für die Themenpartition <topicPartition>
mit der Consumergruppe <groupId> konnten nicht gelesen werden.
INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS
Die anfänglichen Offsets für die Partitionen <partitions> konnten nicht gefunden werden. Möglicherweise wurden sie gelöscht.
PARTITIONS_DELETED
Die Partitionen <partitions> wurden gelöscht.
PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRESENT
Die Partitionen <partitions> wurden gelöscht.
Die Kafka-Option „kafka.<groupIdConfig>“ wurde für diese Abfrage festgelegt. Es wird
nicht empfohlen, diese Option festzulegen. Die Verwendung dieser Option ist nicht sicher. Dies liegt daran, dass mehrere gleichzeitige
Abfragen oder Quellen, die dieselbe Gruppen-ID verwenden, sich gegenseitig beeinträchtigen, da sie Teil
derselben Consumergruppe sind. Neu gestartete Abfragen werden möglicherweise ebenfalls
durch vorherige Ausführung mit derselben Gruppen-ID beeinträchtigt. Der Benutzer sollte nur eine Abfrage pro Gruppen-ID verwenden
und/oder die Option „kafka.session.timeout.ms“ auf einen sehr geringen Wert festlegen, sodass die
Kafka-Consumer der vorherigen Abfrage vom Kafka-Gruppenkoordinator als inaktiv markiert werden, bevor
die neu gestartete Abfrage ausgeführt wird.
PARTITION_OFFSET_CHANGED
Der Offset von Partition <topicPartition> wurde von <prevOffset> in <newOffset> geändert.
START_OFFSET_RESET
Der Startoffset für <topicPartition> war <offset>, wurde vom Consumer aber auf <fetchedOffset> zurückgesetzt.