kafka 실습 (설치)

이전 포스팅에서 kafka 에 대한 내용을 다룬적이 있다.

 

자세한 내용은 아래 참고 포스팅 참고 바란다.

 

이번 포스팅에서는 피시에 카프카를 설치를 하고 직접 springboot 에서 테스트 해보는 코드를 작성해볼 것이다.

 

kafka는 zookeeper를 사용해서 mac 에 설치를 하였다.

 

https://kafka.apache.org/downloads 

Apache Kafka

 

설치가 된 후 과정은 아래와 같다.

 

1. bin/zookeeper-server-start.sh config/zookeeper.properties

를 하여 zookeeper 를 실행한다.

 

2. bin/kafka-server-start.sh config/server.properties

를 하여 kafka를 실행한다.

 

3. server.property 에서 주석해제

advertised.listeners=PLAINTEXT://localhost:9092

 

4. 토픽 생성한다.

bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

(삭제는 create 대신 delete)

 

이렇게 까지 하면 토픽이 생성이 되고 스프링 부트에서 해당 토픽으로 메세지를 프로듀서를 통해서 보내면 컨슈머에서는 이를 받아서 처리를 하게 된다.

 

참고로 현재 토픽의 목록을 보려면 아래 명령어로 가능하다.

bin/kafka-topics.sh --bootstrap-server localhost:9092 --list

 

 

위에 사용된 명령어의 각 설정값은 다음을 의미하니 참고 바란다.

• --create : 토픽 생성
• --topic [ topic-name ] : 생성할 토픽 이름
• --partitions [ number ] : 생성할 토픽의 파티션 개수
• --replication-factor [ number ] : 각 파티션 내 메시지를 복제할 Replica 의 개수
• --bootstrap-server : 연결될 카프사 서버

 

 

---

참고 포스팅

https://thenicesj.tistory.com/259

Apache Kafka 란?