Apache Kafka를 마이크로서비스에서 활용하기 위해서는 먼저 로컬 시스템에 Apache Kafka를 설치하고 설정해야 합니다. 아래는 각 단계에 대한 상세한 설명과 참고 자료입니다.
Apache Kafka 공식 웹사이트 방문:
Kafka 다운로드:
파일 압축 해제:
tar -xzf kafka_2.13-<version>.tgz
여기서 <version>
은 다운로드한 Kafka 버전에 맞게 변경합니다.Kafka 폴더로 이동:
cd kafka_2.13-<version>
Kafka는 두 가지 모드로 실행할 수 있습니다: Zookeeper와 KRaft 모드. KRaft 모드는 Zookeeper 없이 Kafka 클러스터를 운영할 수 있는 최신 방법입니다.
KRaft 모드 설정:
bin/kafka-storage.sh format --cluster-id <cluster-id> --inter.broker.protocol.version <version> --config-file config/kraft/server.properties
<cluster-id>
와 <version>
은 환경에 맞게 설정합니다.Kafka 브로커 시작:
bin/kafka-server-start.sh config/kraft/server.properties
9092
에서 실행됩니다. 브로커가 성공적으로 시작되면, Kafka가 이 포트에서 메시지를 받을 준비가 된 것입니다.Kafka 서버가 실행 중인지 확인하려면, 다음 명령어로 Kafka 브로커가 제대로 작동하는지 확인할 수 있습니다:
netstat -an | grep 9092
이제 Kafka를 설정했으므로, 다음 단계에서는 Kafka를 통해 이벤트 스트리밍과 비동기 통신을 활용하기 위해 계좌 및 메시지 마이크로서비스 코드를 업데이트할 것입니다. 이 과정은 Kafka와 Spring Cloud Stream을 통합하여 구현됩니다.
다음 강의에서는 Kafka와 마이크로서비스 간의 연결 및 이벤트 스트리밍 구현을 다루겠습니다. 감사합니다!