๐Ÿ” ๋‚ด๊ฐ€ ๋ฐฐ์šด ๋‚ด์šฉ ์š”์•ฝ


  1. Kafka๋Š” ๋Œ€์šฉ๋Ÿ‰ ์‹ค์‹œ๊ฐ„ ๋ฐ์ดํ„ฐ ์ŠคํŠธ๋ฆฌ๋ฐ ํ”Œ๋žซํผ
  2. ํ”„๋กœ๋“€์„œ โ†’ ๋ธŒ๋กœ์ปค โ†’ ์ปจ์Šˆ๋จธ ๊ตฌ์กฐ๋กœ ๋™์ž‘
  3. ๋กœ๊ทธ, ์ด๋ฒคํŠธ, ์ŠคํŠธ๋ฆฌ๋ฐ ๋ฐ์ดํ„ฐ๋ฅผ ๋น ๋ฅด๊ฒŒ ์ „๋‹ฌํ•˜๊ณ  ์ฒ˜๋ฆฌํ•  ์ˆ˜ ์žˆ์Œ
  4. ๋Œ€๊ทœ๋ชจ ์‹œ์Šคํ…œ, ๋งˆ์ดํฌ๋กœ์„œ๋น„์Šค, ๋ฐ์ดํ„ฐ ํŒŒ์ดํ”„๋ผ์ธ์˜ ํ•ต์‹ฌ ๊ตฌ์„ฑ ์š”์†Œ๋กœ ์‚ฌ์šฉ๋จ

๐Ÿ“š Kafka๋ž€?



โœ… Kafka์˜ ํ•ต์‹ฌ ๊ฐœ๋…

๊ฐœ๋… ์„ค๋ช…
Producer ๋ฐ์ดํ„ฐ๋ฅผ Kafka๋กœ ์ „์†กํ•˜๋Š” ์ฃผ์ฒด (์˜ˆ: ์•ฑ, ์„ผ์„œ, ์„œ๋ฒ„ ๋“ฑ)
Consumer Kafka์—์„œ ๋ฐ์ดํ„ฐ๋ฅผ ์ฝ๋Š” ์ฃผ์ฒด (์˜ˆ: ๋ถ„์„ ์‹œ์Šคํ…œ, ์•Œ๋ฆผ ์„œ๋น„์Šค ๋“ฑ)
Broker ๋ฉ”์‹œ์ง€๋ฅผ ์ €์žฅํ•˜๊ณ  ๊ด€๋ฆฌํ•˜๋Š” Kafka ์„œ๋ฒ„
Topic ๋ฉ”์‹œ์ง€๋ฅผ ์ฃผ์ œ๋ณ„๋กœ ๋ถ„๋ฅ˜ํ•˜๋Š” ๋‹จ์œ„ (Producer/Consumer๊ฐ€ ๊ณต์œ )
Partition Topic์„ ๋‚˜๋ˆˆ ์กฐ๊ฐ, ๋ณ‘๋ ฌ ์ฒ˜๋ฆฌ์™€ ํ™•์žฅ์„ฑ์„ ๋†’์ž„
Offset Consumer๊ฐ€ ์ฝ์€ ๋ฉ”์‹œ์ง€์˜ ์œ„์น˜ ์ •๋ณด
ZooKeeper ํด๋Ÿฌ์Šคํ„ฐ ์ƒํƒœ ๊ด€๋ฆฌ์™€ ๋ธŒ๋กœ์ปค ์กฐ์ • ๋‹ด๋‹น (Kafka 3.x๋ถ€ํ„ฐ๋Š” ์„ ํƒ ์‚ฌํ•ญ)

โœ… Kafka์˜ ์ฃผ์š” ํŠน์ง•

ํŠน์ง• ์„ค๋ช…
์‹ค์‹œ๊ฐ„ ์ฒ˜๋ฆฌ ์ˆ˜์‹ญ๋งŒ~์ˆ˜๋ฐฑ๋งŒ TPS ์ฒ˜๋ฆฌ ๊ฐ€๋Šฅ
ํ™•์žฅ์„ฑ ๋ธŒ๋กœ์ปค์™€ ํŒŒํ‹ฐ์…˜ ์ˆ˜๋ฅผ ๋Š˜๋ ค ์ˆ˜ํ‰ ํ™•์žฅ ๊ฐ€๋Šฅ
๋‚ด๊ฒฐํ•จ์„ฑ ๋ฉ”์‹œ์ง€๋ฅผ ์—ฌ๋Ÿฌ ๋ธŒ๋กœ์ปค์— ๋ณต์ œํ•ด ์žฅ์•  ๋Œ€๋น„
์˜์†์„ฑ ๋ฉ”์‹œ์ง€๋ฅผ ๋””์Šคํฌ์— ์ €์žฅ, ์ผ์ • ๊ธฐ๊ฐ„ ์œ ์ง€ ๊ฐ€๋Šฅ
๋А์Šจํ•œ ๊ฒฐํ•ฉ Producer์™€ Consumer๊ฐ€ ์ง์ ‘ ์—ฐ๊ฒฐ๋˜์ง€ ์•Š์Œ
์ŠคํŠธ๋ฆฌ๋ฐ ์ฒ˜๋ฆฌ Kafka Streams, ksqlDB ๋“ฑ๊ณผ ์—ฐ๊ณ„ ๊ฐ€๋Šฅ