Kafka Connect 재시작 후 등록한 커넥터가 사라지는 증상이 나타난다.
cleanup.policy=delete이면 retention 시간이 지난 커넥터 설정 레코드가 삭제된다. 설정 데이터가 사라진 뒤에는 재시작 시 커넥터를 복원하지 못할 수 있다.
Connect 내부 connect-config 토픽의 cleanup.policy를 compact로 설정한다.
명령 예시는 문서 작성 시 보강한 것이며 대상 시스템에서 실행 검증하지 않았다.
config.storage.topic을 확인한다. 이름을 connect-config라고 가정하지 않는다.kafka-configs --bootstrap-server '<broker>:9093' --command-config '<admin.properties>' \
--entity-type topics --entity-name '<config.storage.topic>' --describe
kafka-configs --bootstrap-server '<broker>:9093' --command-config '<admin.properties>' \
--entity-type topics --entity-name '<config.storage.topic>' --alter --add-config cleanup.policy=compact
kafka-topics --describe로 config 토픽이 1 partition인지 확인한다. status/offset 토픽의 partition 조건과 혼동하지 않는다.Connect worker 재시작 후 connector 목록과 task 상태가 유지되는지 확인한다.