중요한 파일과 디렉토리
- 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 관리를 위한 Systemd 서비스 유닛:
/etc/systemd/system/kafka.service
Kafka 서비스
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 읽기를 중지합니다.
이벤트는 여러 클라이언트가 여러 번 소비할 수 있습니다.
로그 및 문제 해결
- Kafka 로그:
/opt/kafka/logs - Systemd 저널:
sudo journalctl -u kafka -f - 포트 확인
9092(브로커) 및9093(컨트롤러)이(가) 열려 있습니다.
