- Kafka Streams์ ํต์ฌ ๋ฐ์ดํฐ ์ฒ๋ฆฌ ๋ฉ์๋(filter, map, flatMap, branch ๋ฑ)๋ฅผ Spring Boot ๊ธฐ๋ฐ์ ์ค์๊ฐ ์์ ๋ฅผ ํตํด ์ฌ์ธต์ ์ผ๋ก ํ๊ตฌํฉ๋๋ค. ๐
transaction ID,user ID,amount,item๋ฑ ๋ณต์กํ JSON ๋ฐ์ดํฐ ๊ตฌ์กฐ๋ฅผ ํ์ฉํ์ฌ ๊ฐ ๋ฉ์๋์ ์ค์ ์ ์ฉ ์ฌ๋ก๋ฅผ ๋ณด์ฌ์ค๋๋ค. ๐filter๋ ํน์ ์กฐ๊ฑด์ ๋ง๋ ๋ ์ฝ๋๋ฅผ ์ ํํ๊ณ ,filterNot์ ์กฐ๊ฑด์ ๋ง์ง ์๋ ๋ ์ฝ๋๋ฅผ ์ ์งํ์ฌ ๋ฐ์ดํฐ ํํฐ๋ง์ ์ํํฉ๋๋ค. ๐map์ ๋ ์ฝ๋์ ํค์ ๊ฐ์ ๋ชจ๋ ๋ณํํ์ฌ ๋ฐ์ดํฐ ํ์์ ์ ์ฐํ๊ฒ ๋ณ๊ฒฝํ๋ฉฐ,mapValues๋ ํค๋ ์ ์งํ ์ฑ ๊ฐ๋ง ๋ณํํ์ฌ ํจ์จ์ฑ์ ๋์ ๋๋ค. ๐flatMap์ ์ค์ฒฉ๋ ๊ฐ์ฒด๋ ์ผ๋๋ค ๊ด๊ณ๋ฅผ ๊ฐ์ง ๋ฐ์ดํฐ๋ฅผ ์ฌ๋ฌ ๊ฐ๋ณ ๋ ์ฝ๋๋ก ํํํํ์ฌ ์์ธ ๋ถ์์ ๊ฐ๋ฅํ๊ฒ ํฉ๋๋ค. ๐งฉflatMapValues๋ ํค๋ฅผ ๋ณ๊ฒฝํ์ง ์๊ณ ๊ฐ๋ง ํํํํ์ฌ, ์๋ณธ ํค๋ฅผ ์ ์งํ๋ฉด์ ์ค์ฒฉ๋ ๋ฐ์ดํฐ๋ฅผ ๋ถ๋ฆฌํ ๋ ์ ์ฉํฉ๋๋ค. ๐branch๋ ๋จ์ผ ์คํธ๋ฆผ์ ์ฌ๋ฌ ์กฐ๊ฑด์ ๋ฐ๋ผ ๋ค์์ ํ์ ์คํธ๋ฆผ์ผ๋ก ๋ถํ ํ์ฌ, ๋ฐ์ดํฐ ์ ํ๋ณ ๋ง์ถคํ ์ฒ๋ฆฌ๋ฅผ ๊ฐ๋ฅํ๊ฒ ํฉ๋๋ค. ๐ณ





![[๊บผ๋ด๋ณด๊ธฐ] ๊ฐ๋ฐ์ ํ์ฌ์์ ๊ธฐํ์ฐ์ฃผ๋ฅผ!? ๊ฐ๋ฐํ๋ค ์ง์ณค์ ๋ ํ์ด ๋๋ ๊ณก ์๋กโ
ํ์ผ์๋ IT์ง์ฅ์ธ ์ฃผ๋ง์๋ ๋ฎค์ง์
์ ์ถํ๊ณต์ฐ](https://i2.ytimg.com/vi/qbZdaEdjjtU/hqdefault.jpg)