KAFKA_DATA_LOSS felvillkor

SQLSTATE: 22000

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 offseten [<startOffset>, <endOffset>) för topic-partition <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 sökfrå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 lågt 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_FÖRÄNDRAD

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>.