[클라우드 네이티브] 16. Kafka 동적 확장 파티션 확장

1. 카프카 컨테이너 진입

 

명령어 

cd infra/

docker -compose exec -it kafka /bin/bash

cd /bin

2. 파티션 그룹 확인 후 확장

 

- 컨슈머 그룹의 파티션 정보를 확인

./kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group inventory

 

- 파티션 확장

2~3분뒤 Partition Rebalancing이 일어나면서 두번째 Inventory 서비스도 partition assigned로 바뀌어 message 를 polling 할 수 있는 상태로 변경

./kafka-topics --bootstrap-server 127.0.0.1:9092 --alter --topic pubsub --partitions 2

- 파티션 그룹 후 확인

./kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group inventory

 

3. 연속으로 order 서비스 요청

 

http :8082/orders productId=1 qty=1

 

4. 각 inventory 서비스 재고 확인

 

두 재고 서버 확인해보기 => 모두 재고가 변했다.

http :8083/inventories/1

http :8084/inventories/1