KAFKA_DATA_LOSS, klasa błędów

  • Artykuł

SQLSTATE: 22000

Niektóre dane mogły zostać utracone, ponieważ nie są one już dostępne na platformie Kafka; dane zostały przestarzałe przez platformę Kafka lub temat mógł zostać usunięty przed przetworzeniem wszystkich danych w temacie. Jeśli nie chcesz, aby zapytanie przesyłania strumieniowego nie powiodło się w takich przypadkach, ustaw opcję źródłową failOnDataLoss na false. Przyczyna:

ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO

Dodana partycja <topicPartition> rozpoczyna się od <startOffset> zamiast 0.

COULD_NOT_READ_OFFSET_RANGE

Nie można odczytać rekordów z przesunięciem [<startOffset>, <endOffset>) dla partycji tematu <topicPartition>

z grupą <groupId>odbiorców .

INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS

Nie można odnaleźć początkowych <partitions>przesunięć partycji . Mogły zostać usunięte.

PARTITIONS_DELETED

Partycje <partitions> zostały usunięte.

PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRESENT

Partycje <partitions> zostały usunięte.

Opcja platformy Kafka "kafka".<groupIdConfig> został ustawiony na to zapytanie.

nie zaleca się ustawiania tej opcji. Ta opcja jest niebezpieczna do użycia od wielu współbieżnych

zapytania lub źródła używające tego samego identyfikatora grupy będą zakłócać wzajemnie, ponieważ są częścią

tej samej grupy odbiorców. Ponownie uruchomione zapytania mogą również mieć wpływ na zakłócenia

poprzedni przebieg o tym samym identyfikatorze grupy. Użytkownik powinien mieć tylko jedno zapytanie na identyfikator grupy,

i/lub ustaw opcję "kafka.session.timeout.ms" na bardzo małą, tak aby platforma Kafka

użytkownicy z poprzedniego zapytania są oznaczani jako nieaktywni przez koordynatora grupy platformy Kafka przed

Uruchomiono ponownie uruchomione zapytanie.

PARTITION_OFFSET_CHANGED

Przesunięcie partycji <topicPartition> zostało zmienione z <prevOffset> na <newOffset>.

START_OFFSET_RESET

Przesunięcie początkowe dla <topicPartition> elementu było <offset> , ale resetowanie konsumentów do <fetchedOffset>.