현재 cleanup.policy 확인
$ ./kafka-topics.sh --bootstrap-server localhost:9092 --topic compact-
test --describe
Topic: compact-test PartitionCount: 1 ReplicationFactor: 1 Configs: cleanup.policy=compact,segment.bytes=1073741824
Topic: compact-test Partition: 0 Leader: 0 Replicas: 0Isr: 0kafka-configs.sh를 사용하여 토픽 수정
$ ./kafka-configs.sh --bootstrap-server localhost:9092 --alter --entit
y-type topics --entity-name compact-test --add-config cleanup.policy=delete
Completed updating config for topic compact-test.토픽 변경된 내용 확인
$ ./kafka-topics.sh --bootstrap-server localhost:9092 --topic compact-
test --describe
Topic: compact-test PartitionCount: 1 ReplicationFactor: 1 Configs: cleanup.policy=delete,segment.bytes=1073741824
Topic: compact-test Partition: 0 Leader: 0 Replicas: 0Isr: 0반응형
'빅데이터 > Kafka' 카테고리의 다른 글
| 카프카에서 계층 저장소(Tiered storage)가 필요한 이유 (0) | 2023.10.20 |
|---|---|
| 신뢰성 있는 카프카 애플리케이션을 만드는 3가지 방법 (0) | 2023.09.22 |
| 카프카 프로듀서의 acks=all 옵션은 사실(?) 느리지 않다! (0) | 2023.08.08 |
| Compacted topic에 null key 레코드를 전송하면? (1) | 2023.06.30 |
| 아파치 카프카 Exactly-once 처리의 진실과 거짓 (1) | 2023.06.20 |
| 모던 데이터 플로우: 데이터 파이프라인을 잘 운영하는 방법 (1) | 2023.06.12 |
