kafka 2.1.0 버전에서 주제를 제거하거나 삭제하는 방법

Kafka는 기본적으로 7 일인 168 시간 동안 메시지를 보관합니다. kafka가 주제를 제거하도록 강제하려는 경우 여러 방법으로이를 수행 할 수 있습니다. 각각 자세히 살펴 보겠습니다.

1. kafka-configs.sh 명령 사용

보존 정책을 1 초로 일시적으로 변경합니다.

kafka-configs.sh --zookeeper localhost:2181 --alter --entity-type topics --add-config retention.ms=1000 --entity-name text_topic

아래 명령을 실행하여 보존 정책의 현재 값을 확인할 수 있습니다.

kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --describe --entity-name text_topic
Configs for topic 'text_topic' are retention.ms=1000

1 초 동안 기다린 후 보존 정책 구성을 제거하면 기본값으로 다시 설정됩니다.

kafka-configs.sh --zookeeper localhost:2181 --alter --entity-type topics --delete-config retention.ms --entity-name text_topic

2. 주제를 삭제하고 다시 만듭니다.

기존 주제를 삭제하기 전에 먼저 주제를 다시 생성하는 데 필요하므로 현재 주제의 파티션과 복제본을 가져옵니다. 주제 설명을 실행하여이 정보를 얻을 수 있습니다.

kafka-topics.sh --zookeeper localhost:2181 --describe --topic text_topic

Topic:text_topic        PartitionCount:3        ReplicationFactor:3     Configs:
        Topic: text_topic       Partition: 0    Leader: 0       Replicas: 0     Isr: 0

주제를 삭제하십시오.

kafka-topics.sh --zookeeper localhost:2181 --delete --topic text_topic

복제 및 파티션 세부 정보를 사용하여 주제를 다시 만듭니다.

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic text_topic

3. kafka 로그에서 데이터를 수동으로 삭제합니다.

1. 모든 노드에서 zookeeper 및 kafka를 중지하십시오.
2. 모든 노드에서 kafka 로그를 정리합니다. kafka는 로그 파일을 / tmp / kafka-logs / MyTopic-0에 저장합니다. 여기서 / tmp / kafka-logs는 log.dirattribute에 의해 지정됩니다.
3. zookeeper 및 kafka를 다시 시작하십시오.

도움이 되었기를 바랍니다 !!