Error Handling

모든 오류에 대해 중지

기본적으로 싱크 connector는 오류가 발생하면 종료되고 메시지 처리를 중지합니다. 이것은 싱크 connector에 오류가 발생한 것이 심각한 문제를 나타내는 경우에 좋은 옵션입니다.

싱크 커넥터가 충돌하면 다음 조치 중 하나를 수행한 다음 커넥터를 다시 시작하여 메시지 처리를 재개해야 합니다.

• 싱크 connector 가 일시적으로 오류를 허용하도록 허용

• 메시지를 처리할 수 있도록 싱크 커넥터의 구성을 업데이트하세요.

• 주제에서 잘못된 메시지 제거

errors.tolerance 옵션에 어떤 값도 지정하지 않거나 connector 구성에 다음을 추가하여 오류가 발생했을 때 싱크 connector가 중지되도록 할 수 있습니다.

errors.tolerance=none

모든 오류 허용

모든 오류를 허용하고 메시지 처리를 중단하지 않도록 싱크 connector를 구성할 수 있습니다. 이는 connector를 빠르게 시작하고 실행할 수 있는 좋은 옵션이지만 문제가 발생하면 피드백을 받지 못하므로 connector에 문제가 발생하지 않을 수 있습니다.

다음 옵션을 지정하여 싱크 connector가 모든 오류를 허용하도록 할 수 있습니다.

errors.tolerance=all

데이터 오류 허용

데이터 오류만 허용하고 다른 모든 오류에 대한 처리는 중지하도록 싱크 connector 를 구성할 수 있습니다. 이 설정을 사용하면 connector 는 데드 레터 대기열이 구성된 경우 해당 대기열로 데이터 오류를 보냅니다.

다음 옵션을 지정하여 데이터 오류만 허용하도록 싱크 connector 를 구성합니다.

errors.tolerance=data

주제에 오류 및 잘못된 메시지 쓰기

추가로 검사하거나 처리할 수 있도록 데드 레터 큐 라는 주제에 오류 및 잘못된 메시지를 기록하도록 싱크 connector를 구성할 수 있습니다. 데드 레터 큐는 Apache Kafka와 같은 메시지 큐 시스템에서 시스템이 충돌하거나 오류를 무시하는 대신 잘못된 메시지를 라우팅하는 위치입니다. 데드 레터 큐는 프로그램을 중지한다는 피드백과 모든 오류를 허용하는 내구성을 결합한 것으로, 대부분의 배포에서 좋은 오류 처리 점이 될 수 있습니다.

다음 옵션을 지정하여 connector가 모든 잘못된 메시지를 데드 레터 큐로 라우팅하도록 할 수 있습니다.

errors.tolerance=all
errors.deadletterqueue.topic.name=<name of topic to use as dead letter queue>

오류의 구체적인 이유와 잘못된 메시지를 포함하려면 다음 옵션을 사용하세요.

errors.deadletterqueue.context.headers.enable=true

데드 레터 대기열에 학습 보려면 데드 레터 대기열에 대한 Confluent의 가이드 를 참조하세요.

다른 데드 레터 큐 구성 예시를 보려면 데드 레터 큐 구성 예시를 참조하세요.

connector가 데드 레터 큐에 컨텍스트 헤더로 정의하고 쓰는 예외에 대해 알아보려면 대량 쓰기 예외를 참조하세요.