# 1d = 86400000ms
$ ./bin/kafka-topics.sh --zookeeper <Zookeeper ip address> --alter --topic \
<Topic name> --config retention.ms=86400000

# 변경되었는지 확인 retention.ms=86400000면 성공
$ ./bin/kafka-topics.sh  --describe --zookeeper <Zookeeper ip address> --topic <Topic name>

 

 

참고



https://knight76.tistory.com/entry/kafka%EC%97%90%EC%84%9C-retentionms-%EC%88%98%EC%A0%95%ED%95%98%EB%8A%94-%EB%B0%A9%EB%B2%95

 

kafka에서 retention.ms 수정하는 방법

kafka에서 retention.ms 수정하는 방법은 다음 예처럼 간단한다. $ ./bin/kafka-topics.sh --create --zookeeper zkserver -replication-factor 1 --partitions 1 --topic samuel.test $ ./bin/kafka-topics.sh -..

knight76.tistory.com

 

https://github.com/occidere/TIL/issues/13

 

카프카 데이터 보관주기 설정 · Issue #13 · occidere/TIL

카프카 데이터 보관주기 설정 기본 개념 메시지 보관 기간 설정은 개별 메시지가 아닌 log segment 파일을 대상으로 처리된다. 이를 바탕으로 메시지가 카프카 브로커에 생성될 때, 해당 파티션의 l

github.com

 

'Database > Kafka' 카테고리의 다른 글

Kafka QuickStart  (0) 2020.07.30
centOS 8에 Kafka 설치  (0) 2020.07.28
[MacOS] Cloudkarafka와 python를 연동해서 메세지 전송하기  (0) 2020.07.25
[MacOS] Cloudkarafka로 kafka 맛보기  (1) 2020.07.24

+ Recent posts