중요한 파일과 디렉토리
- 기본 Kafka 설치 디렉터리:
/opt/kafka - Kafka 브로커 구성 파일:
/opt/kafka/config/server.properties - Kafka 로그 디렉터리(브로커 로그, 보관된 이벤트):
/opt/kafka/logs - Kafka 바이너리 및 CLI 도구(
kafka-topics.sh,kafka-console-producer.sh, 등.):/opt/kafka/bin - Kafka 관리를 위한 시스템화된 서비스 단위:
/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 - 시스템 저널:
sudo journalctl -u kafka -f - 포트 확인
9092(브로커) 그리고9093(컨트롤러)가 열려 있습니다.
