[Kafka] 카프카 설치와 실행

Web/Kafka

부에나온다 2022. 8. 2. 10:36

카프카 설치하기

- Docker 를 설치를 해야한다.

- docker-compose.yml 을 통해서 zookeeper 와 kafka를 설치 할 예정이다.

- 디렉토리는 크게 상관없이 작성을 하면 된다.

- docker-compose up -d를 통해 실행하고, 컨테이너 실행 상태를 docker ps 를 통해 체크하자.

- Kafka 설치 진행까지 완료하였으니, Kafka가 잘 작동하는지 테스트를 해보자

- docker exec -it kafka /bin/bash 명령어를 통해 kafka 컨테이너에 접근할 수 있다.

- 그리고 명령어를 통해서 Topic을 생성해보고 확인 해보자.

- kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092 명령어를 통해 토픽 생성

- kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092 명령어를 통해 토픽 상태

--create
새로운 토픽을 만들 때 사용하는 옵션

--topic
create, alter, describe, delete 옵션에 사용할 Topic 명. Topic 이름은 큰따옴표(")로 묶고, 정규식 사용이

가능하므로 escape한다.

--describe
운영상에 필요한 Topic의 상세정보를 보여준다.

  --bootstrap-server
  연결할 Kafka 서버( host:port )!
  이 옵션이 추가되면, 직접 Zookeeper에 연결하지 않아도 된다.

  --replication-factor
  Partition 복제 수. 이 옵션을 사용하지 않으면, 기본 값을 사용한다.
  기본 값은 server.properties 파일에서 default.replication.factor 항목으로 설정 가능

( 설정되어 있지 않을 경우, 추가 작성 )

--partitions
Topic이 생성되거나 변경될 때의 Partition 수. 이 옵션을 사용하지 않으면, 기본 값을 사용한다.

기본 값은 server.properties 파일에서 num.partitions 항목으로 설정 가능.

- 토픽을 생성했으면 해당 토픽에 이벤트를 발생시켜 송수신을 확인해보자