๋ณธ๋ฌธ ๋ฐ”๋กœ๊ฐ€๊ธฐ
๐Ÿ“จ Apache Kafka

[์•„ํŒŒ์น˜ ์นดํ”„์นด ์• ํ”Œ๋ฆฌ์ผ€์ด์…˜ ํ”„๋กœ๊ทธ๋ž˜๋ฐ with ์ž๋ฐ”] 3-2, 3์žฅ ํ† ํ”ฝ๊ณผ ํŒŒํ‹ฐ์…˜, ๋ ˆ์ฝ”๋“œ

by GroovyArea 2023. 3. 27.

ํ† ํ”ฝ

  • ๋ฐ์ดํ„ฐ๋ฅผ ๊ตฌ๋ถ„ํ•˜๊ธฐ ์œ„ํ•ด ์‚ฌ์šฉ๋˜๋Š” ๋‹จ์œ„
  • 1๊ฐœ ์ด์ƒ์˜ ํŒŒํ‹ฐ์…˜ ์†Œ์œ 
  • ๋ฐ์ดํ„ฐ๋ฅผ Record ๋ผ ์นญํ•จ

ํŒŒํ‹ฐ์…˜

  • ๋ณ‘๋ ฌ์ฒ˜๋ฆฌ์˜ ํ•ต์‹ฌ
  • ์ปจ์Šˆ๋จธ์˜ ๊ฐœ์ˆ˜๋ฅผ ๋Š˜๋ฆฌ๋Š” ์Šค์ผ€์ผ ์•„์›ƒ์œผ๋กœ ํ•œ์ •๋œ ์ปจ์Šˆ๋จธ์˜ ์ฒ˜๋ฆฌ๋Ÿ‰์„ ๋ณด์กฐ ๊ฐ€๋Šฅ.
  • Queue์™€ ๊ฐ™์€ ๊ตฌ์กฐ

๋ ˆ์ฝ”๋“œ

  • ํƒ€์ž„ ์Šคํƒฌํ”„, ๋ฉ”์‹œ์ง€ ํ‚ค, ๋ฉ”์‹œ์ง€ ๊ฐ’, ์˜คํ”„์…‹, ํ—ค๋” ๊ตฌ์„ฑ
  • ํ•œ๋ฒˆ ์ ์žฌ๋œ ๋ ˆ์ฝ”๋“œ๋Š” ์ˆ˜์ • ๋ถˆ๊ฐ€ ๋ฐ log retention or capacity์— ๋”ฐ๋ผ ์‚ญ์ œ

ํŠน์ง•

  • ์ƒ์„ฑ๋œ ์‹œ์ ์— Unix Time ์„ค์ • ๋จ,
  • ๋ ˆ์ฝ”๋“œ ์ƒ์„ฑ ์‹œ ํƒ€์ž„ ์Šคํƒฌํ”„๋ฅผ ์„ค์ •ํ•  ์ˆ˜ ์žˆ๋‹ค๋Š” ๊ฒƒ์— ์œ ์˜
  • ๋ฉ”์‹œ์ง€ ํ‚ค๋ฅผ ์ด์šฉํ•˜์—ฌ ํ•ด์‹œ ๊ฐ’์„ ํ† ๋Œ€๋กœ ํŒŒํ‹ฐ์…˜ ์ง€์ • ๊ฐ€๋Šฅ
    • ํ•„์š”์‹œ null ์„ค์ •
  • ๋ฉ”์‹œ์ง€ ๊ฐ’์€ ์ง๋ ฌํ™”, ์—ญ์ง๋ ฌํ™” ๊ฐ€๋Šฅํ•œ ๊ฐ์ฒด๋กœ ์„ค์ • => ๋™์ผํ•œ ํ˜•ํƒœ๋กœ ์ƒํ˜ธ ๊ฐ„ ์ˆ˜ํ–‰
  • ์ปจ์Šˆ๋จธ๊ฐ€ ๋ฐ์ดํ„ฐ๋ฅผ ๊ฐ€์ ธ๊ฐˆ ๋•Œ, ์˜คํ”„์…‹์„ ์‚ฌ์šฉ
    • ์ปจ์Šˆ๋จธ ๊ทธ๋ฃน์ด ์š”์ฒญ ํ•œ ํŒŒํ‹ฐ์…˜ ๋ฒ”์œ„๋ฅผ ๋ช…ํ™•ํžˆ ์ง€์ • ๊ฐ€๋Šฅ,
  • ๋ฉ”ํƒ€ ๋ฐ์ดํ„ฐ๋ฅผ ์ €์žฅํ•˜๋Š” ํ—ค๋”
    • ํ‚ค ๊ฐ’ ํ˜•ํƒœ ๊ฐ€๋Šฅ
๋ฐ˜์‘ํ˜•