개요
오프셋을 재설정하여 소비자 그룹 메시지를 처리하는 Apache Kafka 주제 파티션의 위치를 수동으로 변경할 수 있습니다. 재설정은 일반적으로 오프셋을 이전 위치(예: 주제 시작 부분)로 이동하여 connector 해당 점 부터 앞으로 메시지를 다시 처리합니다. 오프셋을 이후 위치로 이동하여 메시지를 건너뛸 수도 있습니다.
소스 Connector 오프셋 재설정
MongoDB Kafka 소스 connector offset.partition.name 구성 속성 사용하여 오프셋을 재설정하는 방법을 제공합니다. 자세한 학습 은 저장된 오프셋 재설정을 참조하세요.
싱크 Connector 오프셋 재설정
MongoDB MongoDB Kafka 싱크 connector 에 대한 오프셋 재설정을 지원 하지 않습니다. 그러나 Apache Kafka 소비자 그룹 도구를 사용하여 싱크 connector 와 연결된 소비자 그룹 의 오프셋을 재설정할 수 있습니다.
자세한 내용은 Confluent 문서의 Kafka 소비자 그룹 도구 페이지를 참조하십시오.
고려 사항
MongoDB Kafka 소스 connector 또는 MongoDB Kafka 싱크 connector 오프셋을 재설정하기 전에 다음 사항을 고려하세요.
오프셋을 재설정하면 메시지를 건너뛰거나 다시 처리할 수 있으므로 데이터 불일치 또는 데이터 손실이 발생할 수 있습니다. 이 절차는 신중하게 사용하세요.
이 절차의 명령은 MongoDB 배포서버 아닌 Apache Kafka 에서만 작동합니다. 필요한 단계는 제공자와 구성에 따라 다를 수 있습니다. Kafka 제공자의 설명서를 검토하고 제공자 또는 관리자에게 이 절차가 사용자의 환경에 적합한지 확인합니다.