작성
·
345
답변 1
1
김대호님 답변드립니다.
세그먼트의 삭제(policy=delete)와 kafka-delete-records.sh의 동작은 상당히 다릅니다. kafka-delete-records.sh를 수행할 경우에는 low watermark를 특정 레코드에 지정합니다. 그리고 추후 클라이언트가 earliest로 메시지를 요청할 경우 low watermark이후 레코드부터 가져가도록 하는 것이죠.
low watermark에 대한 동작방식과 자세한 설명은 https://cwiki.apache.org/confluence/display/KAFKA/KIP-107%3A+Add+deleteRecordsBefore%28%29+API+in+AdminClient 를 참고하세요!