فئة الخطأ KAFKA_DATA_LOSS

SQLSTATE: 22000

وقد تكون بعض البيانات قد فقدت لأنها لم تعد متوفرة في Kafka؛ إما أن البيانات كانت مسنة من قبل Kafka أو ربما تم حذف الموضوع قبل معالجة جميع البيانات في الموضوع. إذا كنت لا تريد أن يفشل استعلام الدفق في مثل هذه الحالات، فقم بتعيين خيار المصدر failOnDataLoss إلى false. السبب:

ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO

يبدأ القسم <topicPartition> المضاف من <startOffset> بدلا من 0.

COULD_NOT_READ_OFFSET_RANGE

تعذر قراءة السجلات في الإزاحة [<startOffset>، ) <endOffset>لقسم الموضوع <topicPartition>

مع مجموعة <groupId>المستهلكين .

INITIAL_OFFSET_NOT_FOUND_FOR_PARTITIONS

يتعذر العثور على الإزاحات الأولية للأقسام <partitions>. ربما تم حذفها.

PARTITIONS_DELETED

تم حذف الأقسام <partitions> .

PARTITIONS_DELETED_AND_GROUP_ID_CONFIG_PRESENT

تم حذف الأقسام <partitions> .

خيار Kafka 'kafka.<groupIdConfig>' تم تعيينه على هذا الاستعلام، وهو

غير مستحسن لتعيين هذا الخيار. هذا الخيار غير آمن للاستخدام منذ عدة متزامنة

ستتداخل الاستعلامات أو المصادر التي تستخدم معرف المجموعة نفسه مع بعضها البعض لأنها جزء

من نفس مجموعة المستهلكين. قد تعاني الاستعلامات التي تمت إعادة تشغيلها أيضا من تداخل من

التشغيل السابق له نفس معرف المجموعة. يجب أن يكون لدى المستخدم استعلام واحد فقط لكل معرف مجموعة،

و/أو قم بتعيين الخيار "kafka.session.timeout.ms" ليكون صغيرا جدا بحيث يكون Kafka

يتم وضع علامة على المستهلكين من الاستعلام السابق ميتين بواسطة منسق مجموعة Kafka قبل

يبدأ تشغيل الاستعلام الذي تمت إعادة تشغيله.

PARTITION_OFFSET_CHANGED

تم تغيير إزاحة القسم <topicPartition> من <prevOffset> إلى <newOffset>.

START_OFFSET_RESET

كان <offset> بدء الإزاحة ل <topicPartition> ولكن إعادة تعيين المستهلك إلى <fetchedOffset>.