- topics 상태확인 > kafka-topics --zookeeper 10.200.31.8:2181 --describe -- 컨슈머 그룹 조회 /bin/kafka-consumer-groups --bootstrap-server localhost:9091 --list -- 토픽 리스트 /bin/kafka-topics --list --bootstrap-server localhost:9091 --exclude-internal -- 토픽 상세 조회 /bin/kafka-topics --bootstrap-server localhost:9091 --topic ai.analyze.video --describe -- 버전확인 bin/kafka-topics --version -- zookeeper echo srvr | nc localhost 2181 [value 형태로 데이터를 받음] /bin/kafka-console-consumer --bootstrap-server localhost:9091 --topic ai.analyze.video --from-beginning /bin/kafka-console-consumer --bootstrap-server localhost:9091 --topic ic.tracking.fusion.bypass --from-beginning /home/admin/SACP-INSTALL/ # kafka topic 생성 ./kafka-topics --bootstrap-server localhost:19092 --create --topic fastcampus --partitions 20 --replication-factor 3 # kafka에 생성된 토픽 리스트 확인 ./kafka-topics --bootstrap-server localhost:19092 --list # 특정 토픽의 파티션 수, 리플리카 수 등의 상세정보 확인 ./kafka-topics --describe --bootstrap-server localhost:19092 --topic fastcampus # kafka 콘솔 컨슈머 실행 ./kafka-console-consumer --bootstrap-server localhost:19092 --topic fastcampus --from-beginning # kafka 콘솔 프로듀서 실행 ./kafka-console-producer --bootstrap-server localhost:19092 --topic fastcampus ### Topic별 보관주기 변경 ```bash # docker 컨테이너 터미널 접속 docker exec -it kafka1 bash # root로 이동 cd ../.. # 보관기간 설정 30초 bin/kafka-configs --bootstrap-server 10.200.31.6:9091,10.200.31.8:9091,10.200.31.142:9091 --alter --entity-type topics --entity-name ic.tracking.ptz --add-config retention.ms=30000 # segment 용량 설정 100N bin/kafka-configs --bootstrap-server 10.200.31.6:9091,10.200.31.8:9091,10.200.31.142:9091 --alter --entity-type topics --entity-name ic.tracking.ptz --add-config segment.bytes=104857600 # Kafka 설정 변경 (/home/gmt/Docker-Data/zk-cluster/kafka1/server.properties) nano server.properties # 30초마다 체크 log.retention.check.interval.ms=30000 ```