지연이체 서비스 개발기: 은행 점검 시간 끝나면 송금해 드릴게요!

஠஠য়ಕ੉૑ো੉୓ࢲ࠺झ /FXইఃఫ୊ܳ଺ইࢲ ܾܻૉ೧೐׬җࡅܲ܀ߔ प೯ࣘبࠗझ౟সೞӝ द೯଱য়՘ী঳਷ו՛੼

૑ো੉୓

੉୓

૑ো੉୓ ੌ੿दр҃җറ੉୓

஠஠য়ಕ੉૑ো੉୓ࢲ࠺झ

஠஠য়ಕ੉૑ো੉୓ࢲ࠺झ ਷೯੼Ѩदрઙܐറ ࣠Ә೧઱חࢲ࠺झ

૑ো੉୓ࢲ࠺झਤӝ

ҕ૑ ࢎղҕਊݫद૑௸ܳ,BGLB۽੿೮णפ׮ খਵ۽,BGLB݅਍৔ೡѪੑפ׮

3BCCJU.2ӝ߈ ૑ো੉୓ࢲ࠺झਤӝ

૑ো੉୓ࢲ࠺झ੤ࢸ҅

૑ো੉୓ࢲ࠺झחਬ૑غযঠೠ׮

਷೯੼Ѩदрઙܐറ ࣠Ә೧઱ӝ ૑ো੉୓ࢲ࠺झחਬ૑غযঠೠ׮

਷೯ ਷೯੼Ѩदр ۄ੉঱਷೯ _ যೖ஖਷೯ ҕా੼Ѩ ભܰ٣਷೯ _ ೐۽ب਷೯ ҕా੼Ѩ
ઁ੉૑਷೯ ҕా੼Ѩ ௑਷೯ _ ֎য়਷೯ ҕా੼Ѩ ׮নೠ਷೯ ׮নೠ੼Ѩदр ҕా੼Ѩदр _

਋ࢶ೨बӝמ੘زغѱ೧ࠁ੗

૑ো੉୓١۾"1*ѐߊ 6TFS ਷೯੼Ѩઙܐറ ࣠Әغب۾ ૑ো੉୓١۾ೡөਃ

૑ো੉୓١۾"1*ѐߊ 6TFS "1*TFSWFS ૑ো੉୓١۾ ਷೯੼Ѩઙܐറ ࣠Әغب۾ ૑ো੉୓١۾ೡөਃ

૑ো੉୓١۾"1*ѐߊ 6TFS "1*TFSWFS ૑ো੉୓١۾ ੼Ѩ৮ܐदрઑഥ ਷೯ಐ ਷೯੼Ѩઙܐറ ࣠Әغب۾ ૑ো੉୓١۾ೡөਃ

6TFS "1*TFSWFS ૑ো੉୓١۾ %# ੷੢ ੼Ѩ৮ܐदрઑഥ ਷೯ಐ ਷೯੼Ѩઙܐറ ࣠Әغب۾ ૑ো੉୓١۾ೡөਃ
૑ো੉୓١۾"1*ѐߊ ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-":

૑ো੉୓प೯ҳഅ %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-":

૑ো੉୓प೯ҳഅ 4DIFEVMFS ↟ ࠙݃׮ࣻ೯ ↟ ࢚క%&-":   ࣠Әप೯৘੿दрب׳ೠѪٜ3FBE %# ↟
࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-":

૑ো੉୓प೯ҳഅ 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ 4DIFEVMFS ↟ ࣠Әप೯ %# ↟ ࣠Ә੿ࠁ
↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-": ↟ ࠙݃׮ࣻ೯ ↟ ࢚క%&-":   ࣠Әप೯৘੿दрب׳ೠѪٜ3FBE

↟ ࠙݃׮ࣻ೯ ↟ ࢚క%&-":   ࣠Әप೯৘੿दрب׳ೠѪٜ3FBE 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ 4DIFEVMFS
↟ ࣠Әप೯ %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-": ૑ো੉୓प೯ҳഅ ҷ۞тѪэ਷ؘ՘ੋо GFBUѤߑ૓ࢤп

↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-": ↟ ࠙݃׮ࣻ೯ ↟ ࢚క%&-":   ࣠Әप೯৘੿दрب׳ೠѪٜ3FBE

↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-": ↟ ࠙݃׮ࣻ೯ ↟ ࢚క%&-":   ࣠Әप೯৘੿दрب׳ೠѪٜ3FBE ࣻୌѤ

↟ ࣠Әप೯ %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-": ૑ো੉୓प೯ҳഅ ࠙উীࣻୌѤ࣠Ә৮ܐޅೠ׮

↟ ࣠Әप೯ %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-": ૑ো੉୓प೯ҳഅ झா઴۞ܳט۰ࠅө

झா઴۞ܳט۰ࠅө 1SJWBUF "1*TFSWFS 4DIFEVMFS ↟ ࣠Әप೯ %# ↟ ࣠Ә੿ࠁ ↟
࣠Әप೯৘੿दр ↟ ࢚క%&-":

झா઴۞ܳט۰ࠅө VTFS*E VTFS*E VTFS*E Ҁ஖૑ঋѱ3FBE೧ঠೞח੉ग %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр
↟ ࢚క%&-":

झா઴۞ܳט۰ࠅө ࣠Әप೯ࢲߡীࠗ׸ %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-":
1SJWBUF "1*TFSWFS ↟ ࣠Әप೯

1SJWBUF "1*TFSWFS ↟ ࣠Әप೯ %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟
࢚క%&-": झா઴۞ܳט۰ࠅө ࣠Әप೯ࢲߡীࠗ׸ ݫद૑௸ف੗

1SJWBUF "1*TFSWFS ↟ ࣠Әप೯ %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟
࢚క%&-": झா઴۞ܳט۰ࠅө ࣠Әप೯ࢲߡীࠗ׸ ࢎղҕਊݫद૑௸,BGLB۽

,BGLBӝ߈૑ো੉୓प೯ %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-": 4DIFEVMFS ↟
࠙݃׮ࣻ೯

,BGLBӝ߈૑ো੉୓प೯ ,BGLB 1SPEVDF %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-":
4DIFEVMFS ↟ ࠙݃׮ࣻ೯

,BGLBӝ߈૑ো੉୓प೯ ,BGLB 1SPEVDF $POTVNFS $POTVNF %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр
↟ ࢚క%&-": 4DIFEVMFS ↟ ࠙݃׮ࣻ೯

,BGLBӝ߈૑ো੉୓प೯ ,BGLB 1SPEVDF $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF %# ↟
࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-": 4DIFEVMFS ↟ ࠙݃׮ࣻ೯

,BGLB 1SPEVDF $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF 5PQJDUSBOTGFS - EFMBZ
1BSUJUJPO $POTVNFS؀ࣻ ,BGLBӝ߈૑ো੉୓प೯ %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-": 4DIFEVMFS ↟ ࠙݃׮ࣻ೯

,BGLBӝ߈૑ো੉୓प೯ ,BGLB 1SPEVDF $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF 5PQJDUSBOTGFS -
EFMBZ 1BSUJUJPO $POTVNFS؀ࣻ %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-": 4DIFEVMFS ↟ ࠙݃׮ࣻ೯ ,BGLBӝ߈ইఃఫ୊ীࢲب ೨बӝמ੘زػ׮

,BGLBӝ߈૑ো੉୓प೯ ,BGLB 1SPEVDF $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF 5PQJDUSBOTGFS -
EFMBZ 1BSUJUJPO $POTVNFS؀ࣻ %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-": 4DIFEVMFS ↟ ࠙݃׮ࣻ೯

,BGLB 1SPEVDF $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF 5PQJDUSBOTGFS - EFMBZ
1BSUJUJPO $POTVNFS؀ࣻ %# ↟ ࣠Ә੿ࠁ ↟ ࣠Әप೯৘੿दр ↟ ࢚క%&-": 4DIFEVMFS ↟ ࠙݃׮ࣻ೯ ,BGLBӝ߈૑ো੉୓प೯ ష೗ীэ਷࣠ӘѤ੉ऺੌࣻ੓׮

ష೗ীэ਷࣠ӘѤ੉ऺੌࣻ੓׮ ,BGLB 1SPEVDF $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF %# 4DIFEVMFS

,BGLB 1SPEVDF $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF %# 4DIFEVMFS ష೗ীэ਷࣠ӘѤ੉ऺੌࣻ੓׮
઺ࠂ࣠Әߑ૑೧ঠೠ׮

઺ࠂ࣠Әߑ૑ ӝࠄ੸ੋ࢚క୓ఊ۽૒୶о ,BGLB 1SPEVDF $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF %#
4DIFEVMFS

઺ࠂ࣠Әߑ૑ ӝࠄ੸ੋ࢚క୓ఊ۽૒୶о ࢚క%&-": ,BGLB 1SPEVDF $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF
%# 4DIFEVMFS

઺ࠂ࣠Әߑ૑ ӝࠄ੸ੋ࢚క୓ఊ۽૒୶о 4,*1 ,BGLB 1SPEVDF $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF
%# 4DIFEVMFS

4,*1 ,BGLB 1SPEVDF $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF %# 4DIFEVMFS
઺ࠂ࣠Әߑ૑ ӝࠄ੸ੋ࢚క୓ఊ۽૒୶о അ੤ஶगݠ؀

4,*1 ,BGLB 1SPEVDF $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF %# 4DIFEVMFS
઺ࠂ࣠Әߑ૑ ӝࠄ੸ੋ࢚క୓ఊ۽૒୶о ஶगݠ؀ীࢲزदীஶचೡࣻ੓׮

,BGLB 1SPEVDF $POTVNFS %# 4DIFEVMFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ ஶगݠزदࣗ࠺੉ग

ஶगݠزदࣗ࠺੉ग ,BGLB 1SPEVDF $POTVNFS %# 4DIFEVMFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ ৈ੹൤઺ࠂ࣠Ә੉ߊࢤೡࣻ੓׮

ஶगݠزदࣗ࠺੉ग ,BGLB 1SPEVDF $POTVNFS %# 4DIFEVMFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ -PDLਸഝਊೞ੗

ஶगݠزदࣗ࠺۽ੋೠ઺ࠂ࣠Әߑ૑ ,BGLB $POTVNFS

ஶगݠزदࣗ࠺۽ੋೠ઺ࠂ࣠Әߑ૑ 6TFS-PDL੟ӝ ,BGLB $POTVNFS ↟ ࣠Әप೯ ↟ ࢚క߸҃ 6TFS-PDL

ஶगݠزदࣗ࠺۽ੋೠ઺ࠂ࣠Әߑ૑ 6TFS-PDL੟ӝ ↟ ࣠Әप೯ ↟ ࢚క߸҃ 6TFS-PDL ,BGLB $POTVNFS 3FEJTӝ߈
(MPCBM-PDL

(MPCBM-PDL ੉ઁ઺ࠂ࣠Ә਷݄ਸࣻ੓ѷ׮

(MPCBM-PDL 6TFS-PDL৔ೱਵ۽ ࣠Әपಁоטযաѷ׮

ৈ۞Ѥ੄૑ো੉୓١۾оמ

6TFS-PDLਵ۽ੋೠ࣠Әपಁ੉ग ,BGLB $POTVNFS

6TFS-PDLਵ۽ੋೠ࣠Әपಁ੉ग 6TFS-PDL ,BGLB $POTVNFS

6TFS-PDLਵ۽ੋೠ࣠Әपಁ੉ग 6TFS-PDL ,BGLB $POTVNFS э਷ࢎਊ੗੄࣠ӘѤٜ਷ э਷ஶगݠীࢲ୊ܻغب۾ೞ੗

э਷ஶगݠ۽ࠁղ੗ 6TFS-PDL ,BGLB $POTVNFS

э਷ஶगݠ۽ࠁղ੗ 6TFS-PDL ,BGLB $POTVNFS )08

э਷ஶगݠ۽ࠁղ੗ 4DIFEVMFS

э਷ஶगݠ۽ࠁղ੗ ,BGLB 4DIFEVMFS 1SPEVDF 3FDPSE

э਷ஶगݠ۽ࠁղ੗ ,BGLB 4DIFEVMFS 1SPEVDF 3FDPSE UPQJDUSBOTGFS - EFMBZ LFZ6TFS*E WBMVF࣠Ә੿ࠁ

э਷ஶगݠ۽ࠁղ੗ ,BGLB 4DIFEVMFS 1SPEVDF 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO
"

э਷ஶगݠ۽ࠁղ੗ ,BGLB 4DIFEVMFS 1SPEVDF 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO
" #

э਷ஶगݠ۽ࠁղ੗ " ,BGLB $POTVNFS (SPVQ 4DIFEVMFS 1SPEVDF

э਷ஶगݠ۽ࠁղ੗ # ,BGLB $POTVNFS (SPVQ 4DIFEVMFS 1SPEVDF

э਷ஶगݠ۽ࠁղ੗ # ,BGLB $POTVNFS (SPVQ 4DIFEVMFS 1SPEVDF /FX૑ো੉୓ইఃఫ୊

/FX૑ো੉୓ইఃఫ୊ %#

/FX૑ো੉୓ইఃఫ୊ %# 4DIFEVMFS ↟ ࠙݃׮ࣻ೯ ↟ ࢚క%&-":࣠Әप೯৘੿दрب׳ೠѪٜ3FBE

/FX૑ো੉୓ইఃఫ୊ ,BGLB %# 4DIFEVMFS ↟ ࠙݃׮ࣻ೯ UPQJDUSBOTGFS - EFMBZ LFZ6TFS*E
WBMVF࣠Ә੿ࠁ

/FX૑ো੉୓ইఃఫ୊ ,BGLB %# 4DIFEVMFS ↟ ࠙݃׮ࣻ೯ 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO
QBSUJUJPO QBSUJUJPO "

/FX૑ো੉୓ইఃఫ୊ ,BGLB %# 4DIFEVMFS ↟ ࠙݃׮ࣻ೯ 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO
QBSUJUJPO QBSUJUJPO " #

/FX૑ো੉୓ইఃఫ୊ ,BGLB $POTVNFS $POTVNF %# 4DIFEVMFS ↟ ࠙݃׮ࣻ೯

/FX૑ো੉୓ইఃఫ୊ ,BGLB $POTVNFS $POTVNF %# 4DIFEVMFS ↟ ࠙݃׮ࣻ೯ 6TFS-PDL

/FX૑ো੉୓ইఃఫ୊ ,BGLB $POTVNFS $POTVNF %# 4DIFEVMFS ↟ ࠙݃׮ࣻ೯ 6TFS-PDL ࢚క%&-":

/FX૑ো੉୓ইఃఫ୊ ,BGLB $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF %# 4DIFEVMFS ↟
࠙݃׮ࣻ೯ 6TFS-PDL

/FX૑ো੉୓ইఃఫ୊ ,BGLB $POTVNFS 1SJWBUF "1*TFSWFS ࣠Әप೯ਃ୒ $POTVNF %# 4DIFEVMFS ↟
࠙݃׮ࣻ೯ %&-": -> 4&/5 6TFS-PDL

ܾܻૉ

ܾܻૉ೧೐׬ ࠙ ࠙ ৘࢚ അप ਷೯ҕా੼Ѩदр _ ӝળ ૑ো੉୓࣠Әप೯दр

॔ই૑חਬ੷ٜ੄૑ো੉୓ஂࣗਃ୒ٜ ܾܻૉ೧೐׬ GFBUѩী૕ܽ઱פযل ࢜߷दо૑աҊदֈযࢲঠݽפఠ݂ઙܐ QFUFS QFUFS FMNP

૑ো੉୓ࢲ࠺झחݒੌߎ݃׮ߊࢤ

ਗੋ౵ঈ ೧Ѿ పझ౟

ਗੋ౵ঈ ೧Ѿ పझ౟ ܀ߔࠗఠೞ੗

1SPYZܳ੉ਊೠ܀ߔ؀࠺ /FX ૑ো੉୓ࢲߡ VTFS 9

1SPYZܳ੉ਊೠ܀ߔ؀࠺ ӝઓ ૑ো੉୓ࢲߡ /FX ૑ো੉୓ࢲߡ ;VVM1SPYZ VTFS

1SPYZܳ੉ਊೠ܀ߔ؀࠺ ӝઓ ૑ো੉୓ࢲߡ /FX

ੌױ܀ߔ৮ܐ

৵ו۷ਸө

ޙઁ੼ ஶगݠоו۷׮ ,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO $POTVNFS

,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO $POTVNFS ޙઁ੼ஶगݠоו۷׮ प೯ࣘبযڌѱࠗझ౟সೡө

,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO $POTVNFS ޙઁ੼ஶगݠоו۷׮ ࠗझ౟সߑߨਸҊ޹೧ࠁ੗

$POTVNFS $POTVNFS *OTUBODF؀ *OTUBODF/؀ Ҋ޹ ஶगݠ؀ࣻטܻӝ

$POTVNFS $POTVNFS *OTUBODF؀ *OTUBODF؀ Ҋ޹ ஶगݠ؀ࣻטܻӝ ஶगݠ؀ࣻ؀ֈযоݶ੄޷হ׮

Ҋ޹ ஶगݠ؀ࣻטܻӝ ,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO $POTVNFS

Ҋ޹ ౵౭࣌ ஶगݠטܻӝ ,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO
QBSUJUJPO QBSUJUJPO $POTVNFS

Ҋ޹ ౵౭࣌ ஶगݠטܻӝ ,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO
QBSUJUJPO QBSUJUJPO $POTVNFS ౵౭࣌ࣻೠߣטܻݶ׮द઴੉ӝ൨ٜ׮ *OWBMJE1BSUJUJPOT&YDFQUJPO

Ҋ޹ $POTVNFSীDPODVSSFODZࢸ੿ @KafkaListener( topics = ["transfer-delay"], groupId = "kafka-consumer", concurrency
= "3" ) fun listen( @Headers headers: MessageHeaders, @Payload delayMessage: TransferDelayMessage ): ConsumerResult { delaySend(headers, delayMessage) ConsumerResult.success() }

Ҋ޹ $POTVNFSীDPODVSSFODZࢸ੿ ,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO $POTVNFS

,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO $POTVNFS Ҋ޹ $POTVNFSীDPODVSSFODZࢸ੿
୭؀۽౵౭࣌ࣻ݅ఀ݅ࢸ੿੄޷

Ҋ޹ $POTVNFSীDPODVSSFODZࢸ੿ ,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO $POTVNFS

Ҋ޹ $POTVNFSীࢲ࠺زӝ۽प೯ private val executor = Executors.newFixedThreadPool(4) @KafkaListener( topics =
["transfer-delay"], groupId = "kafka-consumer" ) fun listen( @Headers headers: MessageHeaders, @Payload delayMessage: TransferDelayMessage ): ConsumerResult { CompletableFuture.runAsync({ delaySend(headers, delayMessage) }, executor).join() ConsumerResult.success() }

Ҋ޹ $POTVNFSীࢲ࠺زӝ۽प೯ ,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO $POTVNFS

,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO $POTVNFS Ҋ޹ $POTVNFSীࢲ࠺زӝ۽प೯
ױѤݫद૑ஶचਵ۽ח੄޷оহ׮

Ҋ޹ $POTVNFSীࢲ࠺زӝ۽प೯ ,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO $POTVNFS

Ҋ޹ $POTVNFSীࢲ࠺زӝ۽प೯ EFMBZ4FOE NFTTBHF ,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO
QBSUJUJPO $POTVNFS

प೯ࣘبࠗझ౟স೧Ѿ

೧Ѿ ஶगݠ؀ࣻטܻӝ $POTVNFS $POTVNFS ؀ ؀

೧Ѿ ׮Ѥݫद૑ஶच $POTVNFSীࢲ#BUDI3FBE۽ࢸ੿ ,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO
$POTVNFS

೧Ѿ ׮Ѥݫद૑ஶच 3FDPSETࣻח࣠Әप೯ղࠗ"1*ࠗ׸Ҋ۰ ղࠗ "1*TFSWFS ѐ ,BGLB 5PQJDUSBOTGFS - EFMBZ
QBSUJUJPO QBSUJUJPO QBSUJUJPO $POTVNFS

೧Ѿ ׮Ѥݫद૑ஶच @KafkaListener( topics = ["transfer-delay"], containerFactory = "batchKafkaListenerContainerFactory", groupId
= "kafka-consumer", properties = [ "max.poll.records:20" ] ) fun listen( @Headers headers: MessageHeaders, @Payload delayMessages: List<TransferDelayMessage> ): ConsumerResult { return try { delaySend(headers, delayMessages) ConsumerResult.success() } catch (ex: Exception) { log.error { "error:$ex" } ConsumerResult.fail() } } $POTVNFSীࢲ#BUDI3FBE۽ࢸ੿

= "kafka-consumer", properties = [ "max.poll.records:20" ] ) fun listen( @Headers headers: MessageHeaders, @Payload delayMessages: List<TransferDelayMessage> ): ConsumerResult { return try { delaySend(headers, delayMessages) ConsumerResult.success() } catch (ex: Exception) { log.error { "error:$ex" } ConsumerResult.fail() } } $POTVNFSীࢲ#BUDI3FBE۽ࢸ੿ GBDUPSZJT#BUDI-JTUFOFSUSVF GBDUPSZDPOUBJOFS1SPQFSUJFTBDL.PEF$POUBJOFS1SPQFSUJFT"DL.PEF#"5$)

= "kafka-consumer", properties = [ "max.poll.records:20" ] ) fun listen( @Headers headers: MessageHeaders, @Payload delayMessages: List<TransferDelayMessage> ): ConsumerResult { return try { delaySend(headers, delayMessages) ConsumerResult.success() } catch (ex: Exception) { log.error { "error:$ex" } ConsumerResult.fail() } } $POTVNFSীࢲ#BUDI3FBE۽ࢸ੿

= "kafka-consumer", properties = [ "max.poll.records:20" ] ) fun listen( @Headers headers: MessageHeaders, @Payload delayMessages: List<TransferDelayMessage> ): ConsumerResult { return try { delaySend(headers, delayMessages) ConsumerResult.success() } catch (ex: Exception) { log.error { "error:$ex" } ConsumerResult.fail() } } 3FDPSETࣻࢸ੿

೧Ѿ .VMUJUISFBE੸ਊ ,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO QBSUJUJPO QBSUJUJPO $POTVNFS

೧Ѿ .VMUJUISFBE੸ਊ ݾ಴୨प೯दр ୭؀࠙ Ҋ۰ ,BGLB 5PQJDUSBOTGFS - EFMBZ QBSUJUJPO
QBSUJUJPO QBSUJUJPO $POTVNFS ѐ

೧Ѿ .VMUJUISFBE੸ਊ private val forkJoinPool: ForkJoinPool = ForkJoinPool(10) @KafkaListener( topics
= ["transfer-delay"], containerFactory = "batchKafkaListenerContainerFactory", groupId = "kafka-consumer", properties = [ "max.poll.records:20" ] ) fun listen(@Headers headers: MessageHeaders, @Payload delayMessages: List<TransferDelayMessage>): ConsumerResult { return try { val groupedMessages = delayMessages.groupBy { it.payAccountId } forkJoinPool.submit { groupedMessages.values.parallelStream().forEach { messages -> delaySend(headers, messages) } }.join() ConsumerResult.success() } catch (ex: Exception) { log.error { "[ForkJoinPool Exception]. error:$ex" } ConsumerResult.fail() } }

ѐࢶ੹റप೯दр࠺Ү ѐࢶ੹ ѐࢶറ $POTVNFS؀ࣻ 3FBE3FDPSETࣻ 5ISFBEࣻ
࠙׼୊ܻѤࣻ Ѥ Ѥ प೯दр ࠙ ࠙ ਷೯ҕా੼Ѩदрӝળ

प೯ࣘبࠗझ౟স৮ܐ ୊ܻ۝ ૐо प೯ࣘب ߓࡈۄ૗

ܾܻૉ੤दبࢿҕ

ۨѢदࢲߡ#ZF_ ӝઓ ૑ো੉୓ࢲߡ /FX ૑ো੉୓ࢲߡ ;VVM1SPYZ VTFS

ӝઓ ૑ো੉୓ࢲߡ /FX ૑ো੉୓ࢲߡ ;VVM1SPYZ VTFS ۨѢदࢲߡ#ZF_ /FX૑ো੉୓חѨૐ੉غ঻׮

ۨѢदࢲߡ#ZF_ ӝઓ ૑ো੉୓ࢲߡ /FX ૑ো੉୓ࢲߡ ;VVM1SPYZ VTFS

ۨѢदࢲߡ#ZF_ ӝઓ ૑ো੉୓ࢲߡ ;VVM1SPYZ VTFS

द೯଱য়՘ী঳਷ו՛੼

ইఃఫ୊ࢸ҅दӝמҳഅ੉׮оইפ׮ ઺ࠂߊࢤ زदߊࢤ ੸੺ೠ -PDLࢎਊ ׮ܲࢲߡী ޷஖ח৔ೱ

೒ے#؀࠺೧֬੗ য ೒ے#

౟ې೗؀࠺߂੄޷੓חࢿמҊ۰ ౟ې೗؀࠺ ױࣽ൤ं੗ৢܻחѱ   מࢎоইפ׮ /P4JMWFS#VMMFU

૑ো੉୓١۾ೞҊԵਫ਼੗ࣁਃ

지연이체 서비스 개발기: 은행 점검 시간 끝나면 송금해 드릴게요!

지연이체 서비스 개발기: 은행 점검 시간 끝나면 송금해 드릴게요!

More Decks by kakao

Other Decks in Programming

Featured

Transcript