ํ์ฌ์ ๋ค๋๋ค๋ณด๋ ์นดํ์นด๋ฅผ ์ ์ธ ์๊ฐ ์์ด์ ์ด๋ป๊ฒ ์ตํ์ง ํ๋ค๊ฐ ํ์ฌ ๋์๊ด์์ ๋น๋ ค๋ณธ ์ฑ . ์ ์ ๋ ๋ถ์ ์นด์นด์ค์์ ์ ์ฌ ๊ณต์ฉ ์นดํ์นด ํด๋ฌ์คํฐ๋ฅผ ์ด์ํ์๋ ๋ถ๋ค์ธ๋ฐ ๊ทธ๋์ ๊ทธ๋ฐ์ง ์ ๋ง ์ค์ฉ์ ์ธ ๋ด์ฉ๋ง ์์ ๋ด์์ฃผ์ จ๋ค. ๋ด์ฉ์ ์ฝ์ผ๋ฉด์ ์์ฑํ ๋ ธ์ ๋ฉ๋ชจ๋ฅผ ์ฐธ๊ณ ํ์๊ณ โฆ ์ ๋ฐ์ ์ผ๋ก ์์ฒญ ํฐ ํด๋ฌ์คํฐ๋ฅผ ์ด์ํ ๋์ ๊ฟํ, ์ฝ์ง๊ธฐ ๊ทธ๋ฐ ๋ด์ฉ๋ณด๋ค๋ ์นดํ์นด๋ฅผ ์ฒ์ ์ ํ๊ณ ํ 5๋ ๊ท๋ชจ๋ก ์ด์ํด์ผ ํ๋ ๊ฐ๋ฐ์๋ฅผ ์ํด ์ฐ์ฌ์ก๋ค. ์ด์ฉ๋ฉด ์นดํ์นด๊ฐ ์ด์ ๊ฝค ์ฑ์ํด์ ์ค๋ช ์ด ๋ณ๋ก ์๋ ๊ฒ์ผ ์๋ ์๊ฒ ๋๋ฐ ์ด์จ๋ โ์ฃผํคํผ ๊น๊ณ ์นดํ์นด ๊น๊ณ ํ ํฝ ๋ง๋ค๊ณ ํ๋ก๋์ ๋ง๋ค์ด์ ์ปจ์๋จธ๋ก ๊ฐ์ ธ๋ค ์ฐ๊ณ ,,, ๋ชจ๋ํฐ๋ง๋ ํ๊ณ ๊ฐ๋ ์ ๋ฐ์ดํธ๋ ํ๊ณ โํ๋ ํ๋ฆ์ ์ถฉ์คํ๊ฒ ์ง์ด์ฃผ์ ๋ค.
์๋ ์ฑ ์ ์ฝ์ผ๋ฉด ์์ ๋ฅผ ๋ค ๋ฐ๋ผ ์ณ๋ณด๊ณ , ๊ฒฐ๊ณผ๋ ๋ค ํ์ธํ๋ ํธ์ธ๋ฐ ๋๋ฌด ์ค๋ช ์ด ์ ๋์์ด์ ์ง์ ๋ฐ๋ผ์ณ๋ณด์ง ์๊ณ 3์๊ฐ ๋์ ๋น ๋ฅด๊ฒ ์ฝ์๋ค. ๊ทธ๋ ๊ฒ ์ฝ์ด๋ ์ข๊ณ , ์ค์ ๋จธ์ ์ ํ๋์ฉ ๊น์๋ณด๋ฉด์ ๋ฐ๋ผ๊ฐ๋ ์ข์ ์ฑ . ์ญ์๋ณด๋ค๋ ์ด๋ ๊ฒ ํ๊ตญ๋ถ์ด ์ฐ์ ์ข์ ์ฑ ์ ๋ณด๋ฉด ์ฐธ ๋ฐ๊ฐ๋ค.
๋ค์ ์๋ ๋ชฉ์ ์ผ๋ก ๋์์์ ์นดํ์นด๋ฅผ โ์ตํ๋ ค๋ฉดโ ์ด์ ๋ฌด์์ ํด์ผํ ๊น. ์ ์ผ ์ข์ ๊ฒ์ ์ด๊ฑธ ์ด์ฉํ ๋ฌด์ธ๊ฐ๋ฅผ ๋ง๋ค์ด๋ณด๋ ๊ฒ์ธ๋ฐ ๊ทธ๋ฌ๋ ค๋ฉด ์ผ๋จ ์นดํ์นด๋ฅผ ๋์์ผ ํ๋ค. ๋ด๊ฐ ์นดํ์นด๋ฅผ ๋ฆฌ์ผ ๋จธ์ ์ ๊น๋ฉด์ ์ด์ํ ์ผ์ ์์ผ๋ (๊น์๋ ์๋ง k8s์ ๊น ๋ฏโฆ?) ๊ฐํธํ๊ฒ ๋์ปค๋ก ๋์๋ณด์. ์ด๊ด์๋์ ๋ธ๋ก๊ทธ ๊ธ์ด ์ค๋ช ์ด ๊ฐ์ฅ ์ ๋์ด ์์ง๋ง, ํ๊ฐ์ง ์์ฌ์ด ์ ์ kafka-manager๊ฐ ๋น ์ ธ์๋ค๋ ๊ฒ์ด๋ค. ๋ง์ฐฌ๊ฐ์ง๋ก ๋๊ฐ์ง ๋ฐฉ๋ฒ์ด ์๋ค
(19-04-06) ์๋์ ๊ฐ์ ์ฝ์ง์ ํ์ง ๋ง๊ณ ๊ทธ๋ฅ Confluent Platform Quickstart ๋์ปค ์ด๋ฏธ์ง๋ฅผ ์ฐ๋ฉด ํด๊ฒฐ
์นดํ์นด ๋งค๋์ ๋ง ๋ฐ๋ก ๋์ฐ๋ฉด ๊ณ์ ์ฌ๋ฆฌ๊ณ ๋ด๋ฆฌ๊ธฐ ๊ท์ฐฎ์ผ๋๊น ์ ๊ธฐ์ ๋์จ docker-compose-single-broker.yml
๋ฐ์๋ค๊ฐ kafka-manager๋ฅผ ์ถ๊ฐํด์ค๋ค.
(๊ธฐํ ๋ฑ๋ฑ)
kafka-manager:
image: sheepkiller/kafka-manager:latest
ports:
- "9000:9000"
links:
- zookeeper
- kafka
environment:
ZK_HOSTS: zookeeper:2181
APPLICATION_SECRET: letmein
KM_ARGS: -Djava.net.preferIPv4Stack=true
์ด๋ ๊ฒ ํ๋ฉด ์ ๋งํ๊ฑด ๋ค ๋๋๋ฐ, ์ ์ด๋ฏธ์ง๊ฐ ๋น๋๋์ง ์ข ๋์ ์ต์ kafka-manager๊ฐ ๋ด๊ฒจ์์ง ์๋ค. ๋ฐ๋ผ์ ์ต์ ๋ฒ์ ์ ์นดํ์นด๋ฅผ ์ง์ํ์ง ์๊ณ , ๋ช๋ช ์ด์ ๋ค์ ๋ฐ์ ์ ์์ผ๋ ์ ์ด๋ฏธ์ง๋ฅผ ์ด์ง ๊ณ ์ณ์ ์ต์ ๋ฒ์ ์ kafka-manager ์ด๋ฏธ์ง๋ฅผ ๋ง๋ค์ด์ผ ํ๋ค.
sheepkiller/kafka-manager-docker/Dockerfile
๋ฅผ ๋ณด๋ฉด
ENV JAVA_HOME=/usr/java/default/ \
ZK_HOSTS=localhost:2181 \
KM_VERSION=1.3.1.8 \
KM_REVISION=97329cc8bf462723232ee73dc6702c064b5908eb \
KM_CONFIGFILE="conf/application.conf"
์ด๋ ๊ฒ ํ๊ฒฝ ๋ณ์๋ฅผ ์ค์ ํด์ฃผ๋ ๋ถ๋ถ์ด ์๋ค. ์ฌ๊ธฐ์ KM_VERSION
์ด๋ KM_REVISION
์ ์์ ํด์ฃผ๋ฉด ๋๋ค. kafka-manager ๋ฆฌํฌ์ release๋ฅผ ๋ณด๋ฉด ์ต์ ๋ฒ์ ์ด๋ ์ปค๋ฐID๋ฅผ ์ ์ ์๋ค. ๊ทธ๊ฑธ๋ก ํ๊ฒฝ ๋ณ์๋ฅผ ์
๋ฐ์ดํธํ๊ณ ,
ENV JAVA_HOME=/usr/java/default/ \
ZK_HOSTS=localhost:2181 \
KM_VERSION=1.3.3.23 \
KM_REVISION=2ca848bfdf542bf1da8fc860db9bbcc99548f89d \
KM_CONFIGFILE="conf/application.conf"
์๊ฒ์ ์ธ์์ ๊ธฐ๋ค๋ ค์ ์ด๋ฏธ์ง๋ฅผ ๋น๋ํ๋ฉด ๊ฐ๋ฐ์ฉ์ผ๋ก ์ธ๋งํ ์นดํ์นด๋ ์นดํ์นด ๋งค๋์ ๋ฅผ ํธํ๊ฒ ๋์ธ ์ ์๋ค.