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 zakończyło się niepowodzeniem w takich przypadkach, ustaw opcję źródłową failOnDataLoss na false. Powód:
DODANA_PARTYCJA_NIE_ZACZYNA_SIĘ_OD_OFFSETU_ZERO
Dodana partycja <topicPartition> zaczyna się od <startOffset> zamiast 0.
Nie można odczytać zakresu przesunięcia
Nie można odczytać rekordów z offsetu [<startOffset>, <endOffset>) dla tematu partycji <topicPartition>
z grupą odbiorców <groupId>.
Nie znaleziono początkowego przesunięcia dla partycji
Nie można odnaleźć początkowych offsetów partycji <partitions>. Mogły zostać usunięte.
PARTYCJE_USUNIĘTE
Partycje <partitions> zostały usunięte.
PARTYCJE_USUNIĘTE_I_ID_GRUPY_KONFIGURACJA_OBECNA
Partycje <partitions> zostały usunięte.
Opcja Kafka „kafka.<groupIdConfig>” został ustawiony na to zapytanie.
nie zaleca się ustawiania tej opcji. Ta opcja jest niebezpieczna, ponieważ może być używana z wieloma jednoczesnymi procesami.
zapytania lub źródła używające tego samego identyfikatora grupy będą się nawzajem zakłócać, jako że są częścią tej samej grupy.
tej samej grupy odbiorców. Ponownie uruchomione zapytania mogą również doświadczać zakłóceń
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.
ZMIANA_PRZESUNIĘCIA_PARTYCJI
Przesunięcie partycji <topicPartition> zostało zmienione z <prevOffset> na <newOffset>.
START_OFFSET_RESET
Początkowe przesunięcie dla <topicPartition> wynosiło <offset>, ale konsument został zresetowany do <fetchedOffset>.