์นดํ์นด ์๋ฒฝ ๊ฐ์ด๋ - ksqlDB
๋ณธ ๊ฐ์๋ ksqlDB์ ํ์ฉ๊ณผ ํต์ฌ ๋ฉ์ปค๋์ฆ์ ๋ค์ํ ์ค์ต์ ํตํด ์ตํ ์ ์๊ฒ ๊ตฌ์ฑ๋์ด ์์ต๋๋ค. ๊ฐ์๋ฅผ ๋ง์น๊ณ ๋๋ฉด ์ฌ๋ฌ๋ถ์ Kafka(์นดํ์นด) ๊ธฐ๋ฐ์ ์ค์๊ฐ Streaming ๋ฐ์ดํฐ ๋ถ์ ์์คํ ์ ์ฝ๊ณ ๋น ๋ฅด๊ฒ ๊ตฌ์ถํ์ค ์ ์๊ฒ ๋ฉ๋๋ค.
์๊ฐ์ 368๋ช
๋์ด๋ ์ค๊ธ์ด์
์๊ฐ๊ธฐํ ๋ฌด์ ํ
Connect, Elasticsearch ์ฐ๋, ์ค์ ์ค์ต, Kibana ์๊ฐํ ๊ฐ์ ์ถ๊ฐ
์๋ ํ์ญ๋๊น,
ksqlDB 2๋ถ ๊ฐ์๋ฅผ ๋ณ๋๋ก ์ถ์ํ์ง ์๊ณ , ksqlDB 1๋ถ ๊ฐ์์ ์ถ๊ฐ ๊ฐ์๋ฅผ ํตํฉํ ์์ ์ ๋๋ค.
์ถ๊ฐ๋ ๊ฐ์๋ค์ ์ฝ 7~8์๊ฐ ๋ถ๋์ผ๋ก, ์ฃผ์ ๋ด์ฉ์ ์๋์ ๊ฐ์ต๋๋ค.
KSQLDB์ Connect ์ฐ๋
Elasticsearch Sink Connector ์ฐ๋
KSQLDB Use case ์ค์ ์ค์ต
KSQLDB ๋ถ์ ๊ฒฐ๊ณผ๋ฅผ Kibana๋ก ์๊ฐํ
์ถ๊ฐ ๊ฐ์๋ 6์ 8์ผ(๋ชฉ)๊น์ง ๋ชจ๋ ์ ๋ก๋ ํ ์์ ์ด๋ฏ๋ก ๊ธฐ์กด ์๊ฐ์ ๋ถ๋ค์ ๊ณง ์ถ๊ฐ ๊ฐ์๋ฅผ ๋ค์ผ์ค ์ ์์ผ์ค ๊ฒ์ ๋๋ค.
๊ฐ์๋ช ์ ์นดํ์นด ์๋ฒฝ ๊ฐ์ด๋ - ksqlDB ํธ์ผ๋ก ๋ณ๊ฒฝ๋ ๊ฒ์ด๋ฉฐ, ์ถ๊ฐ๋ ๊ฐ์๋ด์ฉ๋ค์ ๋ฐ์ํ์ฌ ๊ฐ์ ์๊ฐ๋ ๋ณ๊ฒฝํ ๊ฒ์ ๋๋ค. ์์ ์๋ฃ ์์ ์ผ์ 6์ 14์ผ ์ ๋๋ค.
๊ฐ์ ๊ธ์ก์ 99,000์์ผ๋ก ์ธ์๋ ์์ ์ด๋ฉฐ (๋น์ฐํ) ๊ธฐ์กด ์๊ฐ์ ๋ถ๋ค์ ์ํฅ์ด ์์ต๋๋ค.
๋ค๋ง ์ธ์ ์ผ์๋ 6์ 14์ผ์ด๋ฉฐ, ๊ทธ๋๊น์ง๋ ํ์ฌ ๊ฐ๊ฒฉ์ด ์ ์ง ๋ฉ๋๋ค.
์ธ์ ๋ ์ ๊ฐ์๋ฅผ ์ฌ๋ํด ์ฃผ์๋ ์๊ฐ์ ๋ถ๋ค๊ป ๋ค์ ํ๋ฒ ๊ฐ์ฌ๋๋ฆฝ๋๋ค.







