KAFKA_DATA_LOSS 오류 클래스
일부 데이터는 더 이상 Kafka에서 사용할 수 없으므로 손실되었을 수 있습니다. Kafka에서 데이터가 오래된 경우 또는 토픽의 모든 데이터가 처리되기 전에 토픽이 삭제되었을 수 있습니다. 이러한 경우 스트리밍 쿼리가 실패하지 않도록 하려면 원본 옵션 failOnDataLoss를 false로 설정합니다. 원인:
ADDED_PARTITION_DOES_NOT_START_FROM_OFFSET_ZERO
추가된 파티션 <topicPartition> 은 0이 아닌 시작됩니다 <startOffset> .
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>' 이 쿼리에서 설정되었습니다.
이 옵션을 설정하지 않는 것이 좋습니다. 이 옵션은 여러 동시이므로 사용하기에 안전하지 않습니다.
동일한 그룹 ID를 사용하는 쿼리 또는 원본은 서로 간섭합니다.
동일한 소비자 그룹의 재시작된 쿼리는 다음의 간섭을 겪을 수도 있습니다.
이전 실행에서 동일한 그룹 ID를 갖습니다. 사용자에게 그룹 ID당 하나의 쿼리만 있어야 합니다.
및/또는 'kafka.session.timeout.ms' 옵션을 매우 작게 설정하여 Kafka를 설정합니다.
이전 쿼리의 소비자는 Kafka 그룹 코디네이터에 의해 죽은 것으로 표시됩니다.
다시 시작된 쿼리가 실행되기 시작합니다.
PARTITION_OFFSET_CHANGED
파티션 <topicPartition> 오프셋이 .로 <newOffset><prevOffset> 변경되었습니다.
START_OFFSET_RESET
에 대한 <topicPartition> 시작 오프셋이지만 소비자는 <offset> .로 다시 설정됩니다 <fetchedOffset>.