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. Orsak:
ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO
Den tillagda partitionen <topicPartition> startar från <startOffset> i stället för 0.
COULD_NOT_READ_OFFSET_RANGE
Det gick inte att läsa poster i förskjutningen [<startOffset>, <endOffset>) för ämnespartition <topicPartition>
med konsumentgruppen <groupId>.
INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS
Det går inte att hitta inledande förskjutningar för partitioner <partitions>. De kan ha tagits bort.
PARTITIONS_DELETED
Partitioner <partitions> har tagits bort.
PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRESENT
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 bara ha en fråga per grupp-ID,
och/eller ange alternativet "kafka.session.timeout.ms" att vara mycket litet så att Kafka
konsumenter från föregående fråga markeras som döda av Kafka-gruppkoordinatorn före
startas om frågan börjar köras.
PARTITION_OFFSET_CHANGED
Partitionsförskjutningen <topicPartition> ändrades från <prevOffset> till <newOffset>.
START_OFFSET_RESET
Startförskjutningen för <topicPartition> var <offset> men konsumentåterställningen till <fetchedOffset>.