Skip to content

[ERROR] kafka mongodb sink connector에서 DELETE 이벤트를 반영하지 못하는 문제 #87

@ddolboghi

Description

@ddolboghi

리팩토링 설명

  • DELETE 이벤트를 받아 mongodb에서 해당 경매글을 삭제합니다.

추가 설명
현재 source connector는 DELETE이벤트를 잘 캡쳐해서 브로커에 보내주지만 mongodb sink connector는 DELETE 이벤트를 받지 못하고 있습니다.
공식적으로 제공하는 connector 설정으로는 이를 해결하지 못했습니다.
남은 방법은 두 가지로 생각합니다.

  1. 경매글에 soft delete 정책 적용
  2. DELETE 이벤트를 받아 삭제하는 custom writestrategy 적용

Metadata

Metadata

Assignees

Labels

bugSomething isn't working

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions