kafka 2.8.2버전 기준입니다.
# 보존 기간을 하루로 설정합니다.
${KAFKA_HOME}/bin/kafka-configs.sh --bootstrap-server ${BOOTSTRAP-SERVERS} --alter --entity-type topics --entity-name ${TOPIC} --add-config retention.ms=86400000
토픽별로 위 명령어로 삭제주기를 설정해두어도, KAFKA 서버 내 server.properties의 내용을 한 번 더 확인하여야합니다.
vi server.properties
log.retention.check.interval.ms = 1000
위 명령어처럼 토픽에 대해 삭제주기를 1일로 설정해두어도 log.retention.check.interval.ms의 값이 1일보다 큰값이면
예상대로 동작하지않습니다. 해당 컨피그는 메시지가 삭제 대상인지를 확인하는 주기입니다.
반응형
'BigData > Kafka' 카테고리의 다른 글
| kafka) kafka PLAINTEXT, SSL 둘 다 사용하기 (0) | 2023.12.28 |
|---|---|
| kafka) kafka SSL설정 (0) | 2023.12.28 |
| kafka) Exception in thread "main" joptsimple.UnrecognizedOptionException: after is not a recognized option kafka topic 삭제주기 (0) | 2023.12.19 |
| Kafka topic producer consumer 테스트 (0) | 2023.07.25 |
| Apache Kafka 설치 (0) | 2023.07.25 |