01.ApacheKafkaandConfluentReferenceArchitecture
Last updated
Last updated
์ด ์ํคํ ์ฒ๋ ํ์ฅ์ ๊ณ ๋ คํด ์ค๊ณ
๊ฐ ๊ตฌ์ฑ ์์๋ ์์ฒด ์๋ฒ๋ฅผ ๊ธฐ๋ฐ ์ผ๋ก ๊ตฌ์ฑ
๋ ธ๋๋ฅผ ์ถ๊ฐํ์ฌ ๋ ๋ฆฝ์ ์ผ๋ก ํ์ฅํ ์ ์์
์๋ก, Confluent REST Proxy๋ฅผ ์ฌ์ฉํ๋ ์ ํ๋ฆฌ์ผ์ด์ ์ ์ถ๊ฐํ ๋ REST Proxy๋ ๋ ์ด์ ํ์ํ ์ฒ๋ฆฌ๋์ ์ ๊ณตํ์ง ๋ชปํ๋ ๋ฐ๋ฉด ๊ธฐ์กด Kafka Broker์๋ ์ฌ์ ํ ์ฌ์ ์ฉ๋์ด ์๋ค๋ฉด, ์ด ๊ฒฝ์ฐ REST Proxy ๋ ธ๋๋ฅผ ์ถ๊ฐํ์ฌ ํ์ฅํ๋ฉด ๋จ
๊ถ๊ณ ๊ฐ์ธ Zookeeper ์๋ฒ 4๋ ์ด์ ๋ฑ ๊ฐ์ข ๋ ธ๋๋ค์ด ์ด์คํ.
๋๋ถ๋ถ Kafka๋ฅผ ์ฒ์ ๋์ ํ๋ ์กฐ์ง์ ๋ถํ๊ฐ ์ ํ๋ ํ๋์ ์ฌ์ฉ ์ฌ๋ก์ ๋ํด Confluent Platform์ ์ฑํํ๋ ๊ฒ์ผ๋ก ์์
์ด ์ฑํ์ด ์ฑ๊ณต์ ์ผ๋ก ์ ์ฆ๋๋ฉด ์กฐ์ง์ ์ถ๊ฐ ์ ํ๋ฆฌ์ผ์ด์ ๊ณผ ํ์ ์์ฉํ ์ ์๋๋ก ํด๋ฌ์คํฐ๋ฅผ ํ์ฅ
์ผ๋ฐ์ ์ผ๋ก ์ด๊ธฐ ๋์ ํ๋ก์ ํธ์ ์ฑ๊ณต์ ์ํด ์ ์ฒด ๋ฐฐํฌ์ ๋ํ ํฌ์๊ฐ ํ์ํ์ง ์์ Confluent Platform ์ฑํ์ ์ด๊ธฐ ๋จ๊ณ์ ์ด ์ํคํ ์ฒ๋ฅผ ๊ถ์ฅ
์ด๋ฌํ ๊ฒฝ์ฐ ๋ ์ ์ ์์ ์๋ฒ๋ก ์์ํ๊ณ ์๋ฒ๋น ์ฌ๋ฌ ๊ตฌ์ฑ ์์๋ฅผ ์ค์นํ๋ ๊ฒ์ ๊ถ์ฅ
Confluent Control Center ๋ฐ Confluent ksqlDB์ ๊ฐ์ ๋ฆฌ์์ค ์ง์ฝ์ ๊ตฌ์ฑ ์์์ ๋ํด์๋ ์ ์ฉ ์๋ฒ๋ฅผ ๊ตฌ์ฑํ๋ ๊ฒ์ ๊ถ์ฅ
SSD ์ฌ์ฉ ๊ถ์ฅ
Connect์ CPU ๊ถ์ฅ์ Connector Worker Node ์ ํํจ. Connector์ ๋์์ CPU์ ์๋ชจ๊ฐ ํด ์ ์๋ค.
HA๋ฅผ ์ํ ๋ ธ๋ ๊ฐ์(์ต์ 2)
2ํ memory : OS ์์ญ 1GB ์ฌ์ฉ๋์ ๋ฐ๋ฅธ + ฮฑ
Core : Cloud Provider๋ ์์คํ ํฌ๊ธฐ๋ฅผ ์กฐ์ ํ ๋ "๊ฐ์" Core๋ฅผ ์ฌ์ฉ ์ผ๋ฐ์ ์ผ๋ก ๋ฐ์ดํฐ ์ผํฐ์์ ์ฌ์ฉํ๋ ์ต์ Core๋ณด๋ค ์ฑ๋ฅ์ด ๋ฎ์ ์ ์์
Network : ๋๋ถ๋ถ์ Cloud Provider๋ ์ต์์ ๊ณ์ธต ๋ ธ๋์์๋ง 10GbE๋ฅผ ์ ๊ณต ๋ณต์ ํธ๋ํฝ์ ๊ณ ๋ คํ ํ์ ์ฒ๋ฆฌ๋์ ์ ๊ณตํ๊ธฐ์ ์ถฉ๋ถํ ๋คํธ์ํฌ ์ฉ๋ ํ์ธ
On-Premises ํ๊ฒฝ์์ ์ค์น์ HW ์ฌ์์ Public Cloud ํ๊ฒฝ์์๋ ๊ถ์ฅ
์ฌ์ฉ๋์ ๋ฐ๋ผ ์ ๋์ ์ผ๋ก sizing ํด์ผํ๋ค.
EBS: SSD ๊ธฐ๋ฐ์ storage
์จํ๋ ๋ฏธ์ค์ Broker, CPU Dual 12-core sockets(24core) ์ ๋ค๋ฅธ๊ฒ์ ์์ ๋ช ์ธ๊ฐ ์ต์ ์ฌ์์ด๊ธฐ ๋๋ฌธ์ด๋ค.