KAFKA_DATA_LOSS felklass
Vissa data kan ha gått förlorade eftersom de inte längre är tillgängliga i Kafka. antingen har data föråldrades ut av Kafka eller så kan ämnet ha tagits bort innan alla data i ämnet bearbetades. Om du inte vill att strömningsfrågan ska misslyckas i sådana fall anger du källalternativet failOnDataLoss till false. Förnuft:
LÄGGD_PARTITION_STARTAR_INTE_FRÅN_OFFSET_NOLL
Partitionen <topicPartition> som har lagts till startar från <startOffset> istället för 0.
KAN_INTE_LÄSA_OFFSET_OMRÅDE
Det gick inte att läsa poster i förskjutningen [<startOffset>, <endOffset>) för ämnespartition <topicPartition>
med konsumentgruppen <groupId>.
INITIAL_OFFSET_EJ_FUNNET_FÖR_PARTITIONER
Det går inte att hitta inledande förskjutningar för partitioner <partitions>. De kan ha tagits bort.
PARTITIONER_RADERADE
Partitioner <partitions> har tagits bort.
PARTITIONER_BORTTAGNA_OCH_GRUPPID_KONFIGURATION_FINNS
Partitioner <partitions> har tagits bort.
Kafka alternativ "kafka.<groupIdConfig>" har ställts in på den här frågan är det
rekommenderas inte att ange det här alternativet. Det här alternativet är osäkert att använda eftersom flera samtidiga
frågor eller källor som använder samma grupp-ID stör varandra eftersom de är en del av
samma konsumentgrupp. Omstartade frågor kan också drabbas av störningar från
tidigare körning med samma grupp-ID. Användaren ska endast ha en fråga per grupp-ID.
och/eller ange alternativet "kafka.session.timeout.ms" till ett mycket litet värde så att Kafka
konsumenter från föregående förfrågan markeras som döda av Kafka-gruppkoordinatorn innan de
Omstartad fråga börjar köras.
PARTITION_OFFSET_CHANGED
Partitionsförskjutningen <topicPartition> har ändrats från <prevOffset> till <newOffset>.
START_OFFSET_RESET
Startförskjutningen för <topicPartition> var <offset> men återställdes av konsumenten till <fetchedOffset>.