KAFKA_DATA_LOSS, klasa błędów
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>.