중요한 파일 및 디렉터리
- 주 카프카 설치 디렉터리:
/opt/kafka - 카프카 브로커 구성 파일:
/opt/kafka/config/server.properties - 카프카 로그 디렉터리 (브로커 로그, 보존 이벤트):
/opt/kafka/logs - 카프카 바이너리 및 CLI 도구 (
kafka-topics.sh,kafka-console-producer.sh등):/opt/kafka/bin - Kafka 관리를 위한 Systemd 서비스 유닛:
/etc/systemd/system/kafka.service
카프카 서비스
sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka
주제 생성
/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
주제 세부 정보 확인:
/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
이벤트 생성 (메시지)
/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
한 줄에 하나의 이벤트를 입력하십시오.
프레스 Ctrl+C 종료하려면.
이벤트 소비
/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
프레스 Ctrl+C 읽기를 멈추다.
이벤트는 여러 클라이언트에 의해 여러 번 소비될 수 있습니다.
로그 및 문제 해결
- 카프카 로그:
/opt/kafka/logs - Systemd 저널:
sudo journalctl -u kafka -f - 포트 확인
9092(중개인) 및9093(컨트롤러)가 열려 있습니다.