IT/Kafka, ๋น๋๊ธฐ ์ฒ๋ฆฌ14 ์คํ๋ง ๋ถํธ์ Kafka๋ฅผ ํ์ฉํ ์ค์ ์ฌ๋ก ์ฐ๊ตฌ: ๋ชจ๋ฒ ์ฌ๋ก์ ์ต์ ๋ํฅ Apache Kafka ๋ ๋๊ท๋ชจ ๋ฐ์ดํฐ ์คํธ๋ฆฌ๋ฐ์ ์ฒ๋ฆฌํ๊ธฐ ์ํ ํ์ ๋๊ตฌ๋ก ์๋ฆฌ ์ก์์ผ๋ฉฐ, ์คํ๋ง ๋ถํธ ์์ ๊ฒฐํฉ์ ์ด๋ฅผ ๋ ์ฝ๊ฒ ํตํฉํ๊ณ ํ์ฅํ ์ ์๊ฒ ํฉ๋๋ค. ์ด ํฌ์คํ ์์๋ ์คํ๋ง ๋ถํธ์ Kafka ๋ฅผ ํ์ฉํ ์ค์ ์ฌ๋ก๋ฅผ ํตํด ํํ ๋ฐ์ํ๋ ๋ฌธ์ ์ ๊ณผ ํด๊ฒฐ ๋ฐฉ๋ฒ, ๊ทธ๋ฆฌ๊ณ ๊ฐ๋ฐ ๋ฐ ๋ฐฐํฌ๋ฅผ ์ํ ๋ชจ๋ฒ ์ฌ๋ก๋ฅผ ์์๋ด ๋๋ค. ๋ํ, ํฅํ ๋ฐ์ ๋ฐฉํฅ๊ณผ ์ต์ ๋ํฅ์ ๋ํด์๋ ๋ค๋ฃฐ ์์ ์ ๋๋ค. 1. ์คํ๋ง ๋ถํธ์ Kafka๋ฅผ ํ์ฉํ ์ค์ ์ฌ๋ก์คํ๋ง ๋ถํธ์ Kafka๋ฅผ ์ฌ์ฉํ๋ ๋ํ์ ์ธ ์ฌ๋ก๋ ์ค์๊ฐ ๋ฐ์ดํฐ ์ฒ๋ฆฌ ์์คํ ์ ๋๋ค. ์ด๋ฅผ ํตํด ๋ก๊ทธ ์ฒ๋ฆฌ, ๋ฐ์ดํฐ ํ์ดํ๋ผ์ธ ๊ตฌ์ถ, ์ค์๊ฐ ์๋ฆผ ์๋น์ค ๋ฑ ๋ค์ํ ๋ถ์ผ์์ Kafka๋ฅผ ํ์ฉํ ์ ์์ต๋๋ค.์ฌ๋ก 1: ์ค์๊ฐ ๋ก๊ทธ ์ฒ๋ฆฌ ์์คํ ๊ธฐ์ A์์๋ .. IT/Kafka, ๋น๋๊ธฐ ์ฒ๋ฆฌ 2024. 10. 23. ๋๋ณด๊ธฐ โบโบ Kafka ์ฑ๋ฅ ํ๋๊ณผ ์ต์ ํ: ๊ณ ์ฒ๋ฆฌ๋ ์๊ตฌ ์ฌํญ ๋์ ๋ฐฉ๋ฒ Apache Kafka ๋ ๊ณ ์ฑ๋ฅ ๋ฐ์ดํฐ ์คํธ๋ฆฌ๋ฐ ํ๋ซํผ์ผ๋ก ๋๋ฆฌ ์ฌ์ฉ๋๊ณ ์์ง๋ง, ๋๊ท๋ชจ ๋ฐ์ดํฐ ํธ๋ํฝ์ ์ฒ๋ฆฌํ๊ธฐ ์ํด์๋ ์ ์ ํ ์ฑ๋ฅ ํ๋ ์ด ํ์์ ์ ๋๋ค. ์ด ํฌ์คํ ์์๋ ํ๋ก๋์ ์ ์ปจ์๋จธ ์ค์ ์ต์ ํ, Kafka ํด๋ฌ์คํฐ ๊ตฌ์ฑ ํ๋ , ์ ํ๋ฆฌ์ผ์ด์ ์ฑ๋ฅ ํ๋กํ์ผ๋ง , ๊ทธ๋ฆฌ๊ณ ๊ณ ์ฒ๋ฆฌ๋ ์๊ตฌ ์ฌํญ ๋์ ๋ฐฉ๋ฒ์ ์ค๋ช ํฉ๋๋ค. 1. ํ๋ก๋์์ ์ปจ์๋จธ ์ค์ ์ต์ ํKafka ์ฑ๋ฅ์ ํต์ฌ ์์๋ ํ๋ก๋์ ์ ์ปจ์๋จธ ์ ์ค์ ์ ๋๋ค. ์ด ์ค์ ๋ค์ด ์ ์ ํ๊ฒ ์กฐ์ ๋์ง ์์ผ๋ฉด ์ฑ๋ฅ ์ ํ๋ฅผ ์ด๋ํ ์ ์์ต๋๋ค. ์๋๋ ์ฃผ์ ํ๋ ์ต์ ๊ณผ ์ค๋ช ์ ๋๋ค.ํ๋ก๋์ ์ต์ ํ ์ค์ a. acks ์ค์ acks=all : ๋ชจ๋ ๋ฆฌํ๋ฆฌ์นด๊ฐ ๋ฐ์ดํฐ๋ฅผ ๋ฐ์ ๋๊น์ง ๋๊ธฐ. ์์ ์ฑ ๋.. IT/Kafka, ๋น๋๊ธฐ ์ฒ๋ฆฌ 2024. 10. 23. ๋๋ณด๊ธฐ โบโบ Confluent Schema Registry๋ก ์คํค๋ง ๊ด๋ฆฌ: Avro ์คํค๋ง ์ฌ์ฉ ๋ฐ ๋ฒ์ ๊ด๋ฆฌ Confluent Schema Registry ๋ Kafka ๋ฐ์ดํฐ์ ์คํค๋ง๋ฅผ ์ค์์์ ๊ด๋ฆฌ ํ๊ณ , ๋ฐ์ดํฐ์ ํธํ์ฑ์ ๋ณด์ฅ ํ๋ ์ค์ํ ๋๊ตฌ์ ๋๋ค. Kafka์ ํจ๊ป Avro , JSON , Protobuf ๊ฐ์ ๋ฐ์ดํฐ ํฌ๋งท์ ์ฌ์ฉํ์ฌ ๋ฐ์ดํฐ์ ์คํค๋ง๋ฅผ ๊ด๋ฆฌํ ์ ์์ผ๋ฉฐ, ์คํค๋ง์ ๋ฒ์ ๊ด๋ฆฌ ์ ํธํ์ฑ ์ ์ฑ ์ ์ ์ฉํ์ฌ ์์คํ ์ ์ผ๊ด์ฑ์ ์ ์งํ ์ ์์ต๋๋ค. ์ด๋ฒ ํฌ์คํ ์์๋ Schema Registry ์ ์๊ฐ์ ํจ๊ป, ์คํค๋ง ๋ฒ์ ๊ด๋ฆฌ ๋ฐฉ๋ฒ, ์คํ๋ง ๋ถํธ์์ Avro ์คํค๋ง ๋ฅผ ์ฌ์ฉํ๋ ๋ฐฉ๋ฒ, ๊ทธ๋ฆฌ๊ณ ์คํค๋ง ์ ์ฑ ์ ์ด๋ป๊ฒ ์ค์ ํ๋์ง ๋ค๋ฃจ๊ฒ ์ต๋๋ค. 1. Schema Registry ์๊ฐ Schema Registry ๋ Kafka์์ ์ฌ์ฉ๋๋ ๋ฐ์ดํฐ ์คํค.. IT/Kafka, ๋น๋๊ธฐ ์ฒ๋ฆฌ 2024. 10. 23. ๋๋ณด๊ธฐ โบโบ Kafka Connect๋ฅผ ํตํ ๋ฐ์ดํฐ ํตํฉ: ํจ์จ์ ์ธ ๋ฐ์ดํฐ ํ์ดํ๋ผ์ธ ๊ตฌ์ถํ๊ธฐ Apache Kafka Connect ๋ Kafka๋ฅผ ์ฌ์ฉํ์ฌ ๋ค์ํ ๋ฐ์ดํฐ ์์ค์ ์ฑํฌ๋ฅผ ์ฝ๊ฒ ํตํฉํ ์ ์๋ ํ๋ ์์ํฌ์ ๋๋ค. ์ด๋ฅผ ํตํด ๋ฐ์ดํฐ๋ฒ ์ด์ค, ํ์ผ ์์คํ , ํด๋ผ์ฐ๋ ์๋น์ค ๋ฑ ์ฌ๋ฌ ์์คํ ๊ฐ์ ๋ฐ์ดํฐ๋ฅผ ์๋์ผ๋ก ์ด๋ ์ํค๋ ๋ฐ์ดํฐ ํ์ดํ๋ผ์ธ์ ๊ตฌ์ถํ ์ ์์ต๋๋ค. ์ด๋ฒ ํฌ์คํ ์์๋ Kafka Connect ์ ๊ฐ์, ๋ฐ์ดํฐ๋ฒ ์ด์ค ์ฐ๋์ ์ํ ์ปค๋ฅํฐ ์ฌ์ฉ , ์ฌ์ฉ์ ์ ์ ์ปค๋ฅํฐ ๊ตฌํ , ๊ทธ๋ฆฌ๊ณ ๋ฐ์ดํฐ ๋ง์ด๊ทธ๋ ์ด์ ์ ๋ต ์ ๋ํด ๋ค๋ฃน๋๋ค. 1. Kafka Connect ๊ฐ์ Kafka Connect ๋ Kafka ํด๋ฌ์คํฐ๋ฅผ ์ฌ์ฉํด ๋ฐ์ดํฐ๋ฅผ ๋ค์ํ ์์คํ ์ผ๋ก๋ถํฐ ๊ฐ์ ธ์ค๊ฑฐ๋ ๋ฐ๋๋ก ๋ด๋ณด๋ด๋ ๋ฐ ์ฌ์ฉ๋ฉ๋๋ค. Source ์ปค๋ฅํฐ ๋ ์ธ๋ถ ์์คํ ์์ ๋ฐ์ดํฐ๋ฅผ Kafk.. IT/Kafka, ๋น๋๊ธฐ ์ฒ๋ฆฌ 2024. 10. 23. ๋๋ณด๊ธฐ โบโบ ์ด๋ฒคํธ ์ฃผ๋ํ ๋ง์ดํฌ๋ก์๋น์ค ์ํคํ ์ฒ: Kafka๋ก ํ์ฅ ๊ฐ๋ฅํ ๋ง์ดํฌ๋ก์๋น์ค ์ค๊ณํ๊ธฐ ์ด๋ฒคํธ ์ฃผ๋ํ ๋ง์ดํฌ๋ก์๋น์ค ์ํคํ ์ฒ ๋ ํ๋ ์ํํธ์จ์ด ๊ฐ๋ฐ์์ ์ค์ํ ํจ๋ฌ๋ค์์ ๋๋ค. ์ด ์ํคํ ์ฒ๋ ์๋น์ค ๊ฐ์ ๊ฒฐํฉ๋๋ฅผ ๋ฎ์ถ๊ณ , ์์คํ ํ์ฅ์ฑ์ ๊ทน๋ํํ๋ฉฐ, ๋น๋๊ธฐ ์ด๋ฒคํธ ์ฒ๋ฆฌ๋ฅผ ํตํด ์ฑ๋ฅ์ ์ต์ ํํ ์ ์์ต๋๋ค. ์ด๋ฒ ํฌ์คํ ์์๋ Kafka ๋ฅผ ํ์ฉํ ์ด๋ฒคํธ ์ฃผ๋ํ ๋ง์ดํฌ๋ก์๋น์ค ์ค๊ณ, ์ด๋ฒคํธ ์์ฑ๊ณผ CQRS ํจํด ์ ์ฉ, ์๋น์ค ๊ฐ ํต์ ์ฒ๋ฆฌ , ๊ทธ๋ฆฌ๊ณ Kafka๋ก ๋ง์ดํฌ๋ก์๋น์ค๋ฅผ ํ์ฅํ๋ ๋ฐฉ๋ฒ ์ ๋ค๋ฃน๋๋ค. 1. Kafka๋ฅผ ํ์ฉํ ๋ง์ดํฌ๋ก์๋น์ค ์ค๊ณKafka๋ ๋ฉ์์ง ๋ธ๋ก์ปค ๋ก์ ์ด๋ฒคํธ ๊ธฐ๋ฐ ์ํคํ ์ฒ์์ ์ค์ํ ์ญํ ์ ํฉ๋๋ค. ์๋น์ค ๊ฐ ๋น๋๊ธฐ ํต์ ์ ๊ฐ๋ฅํ๊ฒ ํ๋ฉฐ, ๋ฐ์ดํฐ๋ฅผ ํํฐ์ ์ผ๋ก ๋ถํ ํ์ฌ ๋๊ท๋ชจ ํธ๋ํฝ ์ฒ๋ฆฌ์ ์ ํฉํฉ๋๋ค.Kafka ๊ธฐ๋ฐ ์ด๋ฒคํธ ์ฒ๋ฆฌ ์์.. IT/Kafka, ๋น๋๊ธฐ ์ฒ๋ฆฌ 2024. 10. 23. ๋๋ณด๊ธฐ โบโบ ์ด์ 1 2 3 ๋ค์