- ÇöÀç À§Ä¡
- home > ÄÄÇ»ÅÍ¡¤ICT¡¤¾îÇÐ > ÄÄÇ»ÅÍ¡¤IT µµ¼ > Àü»êÅë°è/Çؼ® > ¾ÆÆÄÄ¡ Ä«ÇÁÄ« ¾ÖÇø®ÄÉÀÌ¼Ç ÇÁ·Î±×·¡¹Ö with ÀÚ¹Ù[ºñÁ¦ÀÌÆÛºí¸¯]
¾ÆÆÄÄ¡ Ä«ÇÁÄ« ¾ÖÇø®ÄÉÀÌ¼Ç °³¹ßÀ» À§ÇÑ ¡¸½ÇÀü °¡À̵塹
¾ÆÆÄÄ¡ Ä«ÇÁÄ«¶õ ¹«¾ùÀϱî? Ä«ÇÁÄ« ¾ÖÇø®ÄÉÀ̼ÇÀº ¾î¶»°Ô ¸¸µé±î? µ¥ÀÌÅÍ ÆÄÀÌÇÁ¶óÀÎÀ» ¸¸µé±â À§ÇØ ¾î¶² Ä«ÇÁÄ« ¶óÀ̺귯¸®¸¦ »ç¿ëÇØ¾ß ÇÒ±î? Ŭ¶ó¿ìµå ±â¹Ý ¾ÆÆÄÄ¡ Ä«ÇÁÄ«´Â ¾î¶² ±â´ÉÀ» °¡Áö°í ÀÖÀ»±î?
ÀÌ Ã¥Àº ¾ÆÆÄÄ¡ Ä«ÇÁÄ«ÀÇ ±âº»ÀûÀÎ °³³ä°ú »ó¿ë ÇÁ·ÎÁ§Æ®¿¡ Ä«ÇÁÄ«¸¦ »ç¿ëÇÏ´Â ¹æ¾È, ±×¸®°í Äڵ带 ±â¹ÝÀ¸·Î ¿¬µ¿ ¾ÖÇø®ÄÉÀ̼ÇÀ» °³¹ßÇÏ´Â °úÁ¤À» ¼Ò°³ÇÑ´Ù. ¶ÇÇÑ, ¡¸½ÇÀü ÇÁ·ÎÁ§Æ®¡¹¿¡¼ ½Ç¹«¿¡ ¸¹ÀÌ »ç¿ëµÇ´Â ¾ÆÅ°ÅØó¿Í À¯»çÇÑ ±¸Á¶·Î ½Ç½ÀÀ» ÁøÇàÇÏ¸ç »ó¿ë ȯ°æ¿¡¼ ¾î¶»°Ô µ¥ÀÌÅÍ ÆÄÀÌÇÁ¶óÀÎÀ» ±¸ÃàÇÏ´ÂÁö ¼³¸íÇÑ´Ù.
ÀÌ Ã¥À» ÅëÇØ Ä«ÇÁÄ«¿Í ¿¬°üµÈ Ç÷§Æûµé°úÀÇ °ü°è¸¦ ÀüüÀûÀ¸·Î ÀÌÇØÇÏ´Â °ÍÀ» ³Ñ¾î Ä«ÇÁÄ«¸¦ ¾÷¹«¿¡ ¼º°øÀûÀ¸·Î µµÀÔÇÏ°í ¾ÈÁ¤ÀûÀ¸·Î ¿î¿µÇÒ ¼ö ÀÖÀ» °ÍÀÌ´Ù.
[ÀÌ Ã¥ÀÇ ÁÖ¿ä ³»¿ë]
- ¹Ì·¯¸ÞÀÌÄ¿2
- Ä«ÇÁÄ« Ä¿³ØÆ®
- Ä«ÇÁÄ« ¸í·É¾î
- Ä«ÇÁÄ« ½ºÆ®¸²Áî
- Ä«ÇÁÄ« Ŭ¶óÀ̾ðÆ®(ÄÁ½´¸Ó, ÇÁ·Îµà¼, ¾îµå¹Î)
- Ŭ¶ó¿ìµå Ä«ÇÁÄ«(Confluent Cloud, AWS MSK)
- ½ºÇÁ¸µ Ä«ÇÁÄ«
¾ÆÆÄÄ¡ Ä«ÇÁÄ«¶õ ¹«¾ùÀϱî? Ä«ÇÁÄ« ¾ÖÇø®ÄÉÀ̼ÇÀº ¾î¶»°Ô ¸¸µé±î? µ¥ÀÌÅÍ ÆÄÀÌÇÁ¶óÀÎÀ» ¸¸µé±â À§ÇØ ¾î¶² Ä«ÇÁÄ« ¶óÀ̺귯¸®¸¦ »ç¿ëÇØ¾ß ÇÒ±î? Ŭ¶ó¿ìµå ±â¹Ý ¾ÆÆÄÄ¡ Ä«ÇÁÄ«´Â ¾î¶² ±â´ÉÀ» °¡Áö°í ÀÖÀ»±î?
ÀÌ Ã¥Àº ¾ÆÆÄÄ¡ Ä«ÇÁÄ«ÀÇ ±âº»ÀûÀÎ °³³ä°ú »ó¿ë ÇÁ·ÎÁ§Æ®¿¡ Ä«ÇÁÄ«¸¦ »ç¿ëÇÏ´Â ¹æ¾È, ±×¸®°í Äڵ带 ±â¹ÝÀ¸·Î ¿¬µ¿ ¾ÖÇø®ÄÉÀ̼ÇÀ» °³¹ßÇÏ´Â °úÁ¤À» ¼Ò°³ÇÑ´Ù. ¶ÇÇÑ, ¡¸½ÇÀü ÇÁ·ÎÁ§Æ®¡¹¿¡¼ ½Ç¹«¿¡ ¸¹ÀÌ »ç¿ëµÇ´Â ¾ÆÅ°ÅØó¿Í À¯»çÇÑ ±¸Á¶·Î ½Ç½ÀÀ» ÁøÇàÇÏ¸ç »ó¿ë ȯ°æ¿¡¼ ¾î¶»°Ô µ¥ÀÌÅÍ ÆÄÀÌÇÁ¶óÀÎÀ» ±¸ÃàÇÏ´ÂÁö ¼³¸íÇÑ´Ù.
ÀÌ Ã¥À» ÅëÇØ Ä«ÇÁÄ«¿Í ¿¬°üµÈ Ç÷§Æûµé°úÀÇ °ü°è¸¦ ÀüüÀûÀ¸·Î ÀÌÇØÇÏ´Â °ÍÀ» ³Ñ¾î Ä«ÇÁÄ«¸¦ ¾÷¹«¿¡ ¼º°øÀûÀ¸·Î µµÀÔÇÏ°í ¾ÈÁ¤ÀûÀ¸·Î ¿î¿µÇÒ ¼ö ÀÖÀ» °ÍÀÌ´Ù.
[ÀÌ Ã¥ÀÇ ÁÖ¿ä ³»¿ë]
- ¹Ì·¯¸ÞÀÌÄ¿2
- Ä«ÇÁÄ« Ä¿³ØÆ®
- Ä«ÇÁÄ« ¸í·É¾î
- Ä«ÇÁÄ« ½ºÆ®¸²Áî
- Ä«ÇÁÄ« Ŭ¶óÀ̾ðÆ®(ÄÁ½´¸Ó, ÇÁ·Îµà¼, ¾îµå¹Î)
- Ŭ¶ó¿ìµå Ä«ÇÁÄ«(Confluent Cloud, AWS MSK)
- ½ºÇÁ¸µ Ä«ÇÁÄ«
ÀúÀÚ: ÃÖ¿ø¿µ
1.1 Ä«ÇÁÄ«ÀÇ Åº»ý
1.2 ºòµ¥ÀÌÅÍ ÆÄÀÌÇÁ¶óÀο¡¼ Ä«ÇÁÄ«ÀÇ ¿ªÇÒ
1.3 µ¥ÀÌÅÍ ·¹ÀÌÅ© ¾ÆÅ°ÅØó¿Í Ä«ÇÁÄ«ÀÇ ¹Ì·¡
1.4 Á¤¸®
[2Àå] Ä«ÇÁÄ« ºü¸£°Ô ½ÃÀÛÇغ¸±â
2.1 ½Ç½À¿ë Ä«ÇÁÄ« ºê·ÎÄ¿ ¼³Ä¡
2.1.1 AWS EC2 ÀνºÅϽº ¹ß±Þ ¹× º¸¾È ¼³Á¤
2.1.2 ÀνºÅϽº¿¡ Á¢¼ÓÇϱâ
______ssh ¸í·É¾î·Î Á¢¼ÓÇϱâ
______putty·Î Á¢¼ÓÇϱâ
2.1.3 ÀνºÅϽº¿¡ ÀÚ¹Ù ¼³Ä¡
2.1.4 ÁÖÅ°ÆÛ¡¤Ä«ÇÁÄ« ºê·ÎÄ¿ ½ÇÇà
______Ä«ÇÁÄ« ºê·ÎÄ¿ Èü ¸Þ¸ð¸® ¼³Á¤
______Ä«ÇÁÄ« ºê·ÎÄ¿ ½ÇÇà ¿É¼Ç ¼³Á¤
______ÁÖÅ°ÆÛ ½ÇÇà
______Ä«ÇÁÄ« ºê·ÎÄ¿ ½ÇÇà ¹× ·Î±× È®ÀÎ
2.1.5 ·ÎÄà ÄÄÇ»ÅÍ¿¡¼ Ä«ÇÁÄ«¿Í Åë½Å È®ÀÎ
______Å×½ºÆ® ÆíÀǸ¦ À§ÇÑ hosts ¼³Á¤
2.2 Ä«ÇÁÄ« Ä¿¸Çµå ¶óÀÎ Åø
2.2.1 kafka-topics.sh
______ÅäÇÈ »ý¼º
______ÅäÇÈ ¸®½ºÆ® Á¶È¸
______ÅäÇÈ »ó¼¼ Á¶È¸
______ÅäÇÈ ¿É¼Ç ¼öÁ¤
2.2.2 kafka-console-producer.sh
2.2.3 kafka-console-consumer.sh
2.2.4 kafka-consumer-groups.sh
2.2.5 kafka-verifiable-producer, consumer.sh
2.2.6 kafka-delete-records.sh
2.3 Á¤¸®
[3Àå] Ä«ÇÁÄ« ±âº» °³³ä ¼³¸í
3.1 Ä«ÇÁÄ« ºê·ÎÄ¿ ¡¤ Ŭ·¯½ºÅÍ ¡¤ ÁÖÅ°ÆÛ
______µ¥ÀÌÅÍ ÀúÀå, Àü¼Û
______µ¥ÀÌÅÍ º¹Á¦, ½ÌÅ©
______ÄÁÆ®·Ñ·¯(controller)
______µ¥ÀÌÅÍ »èÁ¦
______ÄÁ½´¸Ó ¿ÀÇÁ¼Â ÀúÀå
______ÄÚµð³×ÀÌÅÍ(coordinator)
3.2 ÅäÇÈ°ú ÆÄƼ¼Ç
______ÅäÇÈ À̸§ Á¦¾à Á¶°Ç
______ÀÇ¹Ì ÀÖ´Â ÅäÇÈ À̸§ ÀÛ¸í ¹æ¹ý
3.3_·¹ÄÚµå
3.4 Ä«ÇÁÄ« Ŭ¶óÀ̾ðÆ®
3.4.1 ÇÁ·Îµà¼ API
______Ä«ÇÁÄ« ÇÁ·Îµà¼ ÇÁ·ÎÁ§Æ® »ý¼º
______ÇÁ·Îµà¼ Áß¿ä °³³ä
______ÇÁ·Îµà¼ ÁÖ¿ä ¿É¼Ç
______¸Þ½ÃÁö Å°¸¦ °¡Áø µ¥ÀÌÅ͸¦ Àü¼ÛÇÏ´Â ÇÁ·Îµà¼
______Ä¿½ºÅÒ ÆÄƼ¼Å³Ê¸¦ °¡Áö´Â ÇÁ·Îµà¼
______ºê·ÎÄ¿ Á¤»ó Àü¼Û ¿©ºÎ¸¦ È®ÀÎÇÏ´Â ÇÁ·Îµà¼
3.4.2 ÄÁ½´¸Ó API
______Ä«ÇÁÄ« ÄÁ½´¸Ó ÇÁ·ÎÁ§Æ® »ý¼º
______ÄÁ½´¸Ó Áß¿ä °³³ä
______ÄÁ½´¸Ó ÁÖ¿ä ¿É¼Ç
______µ¿±â ¿ÀÇÁ¼Â Ä¿¹Ô
______ºñµ¿±â ¿ÀÇÁ¼Â Ä¿¹Ô
______¸®¹ë·±½º ¸®½º³Ê¸¦ °¡Áø ÄÁ½´¸Ó
______ÆÄƼ¼Ç ÇÒ´ç ÄÁ½´¸Ó
______ÄÁ½´¸Ó¿¡ ÇÒ´çµÈ ÆÄƼ¼Ç È®ÀÎ ¹æ¹ý
______ÄÁ½´¸ÓÀÇ ¾ÈÀüÇÑ Á¾·á
3.4.3 ¾îµå¹Î API
______ºê·ÎÄ¿ Á¤º¸ Á¶È¸
______ÅäÇÈ Á¤º¸ Á¶È¸
3.5 Ä«ÇÁÄ« ½ºÆ®¸²Áî
3.5.1 ½ºÆ®¸²ÁîDSL
______KStream
______KTable
______GlobalKTable
______½ºÆ®¸²ÁîDSL ÁÖ¿ä ¿É¼Ç
______½ºÆ®¸²ÁîDSL - stream( ), to( )
______½ºÆ®¸²ÁîDSL - filter( )
______½ºÆ®¸²ÁîDSL - KTable°ú KStreamÀ» join( )
______½ºÆ®¸²ÁîDSL - GlobalKTable°ú KStreamÀ» join( )
3.5.2 ÇÁ·Î¼¼¼ API
3.6 Ä«ÇÁÄ« Ä¿³ØÆ®
______Ä¿³ØÆ®¸¦ ½ÇÇàÇÏ´Â ¹æ¹ý
______´ÜÀÏ ¸ðµå Ä¿³ØÆ®
______ºÐ»ê ¸ðµå Ä¿³ØÆ®
3.6.1 ¼Ò½º Ä¿³ØÅÍ
______ÆÄÀÏ ¼Ò½º Ä¿³ØÅÍ ±¸Çö
3.6.2 ½ÌÅ© Ä¿³ØÅÍ
______ÆÄÀÏ ½ÌÅ© Ä¿³ØÅÍ ±¸Çö
3.7 Ä«ÇÁÄ« ¹Ì·¯¸ÞÀÌÄ¿2
3.7.1 ¹Ì·¯¸ÞÀÌÄ¿2¸¦ È°¿ëÇÑ Áö¸®Àû º¹Á¦(Geo-Replication)
3.8 Á¤¸®
[4Àå] Ä«ÇÁÄ« »ó¼¼ °³³ä ¼³¸í
4.1 ÅäÇÈ°ú ÆÄƼ¼Ç
4.1.1 ÀûÁ¤ ÆÄƼ¼Ç °³¼ö
4.1.2 ÅäÇÈ Á¤¸® Á¤Ã¥(cleanup.policy)
______ÅäÇÈ »èÁ¦ Á¤Ã¥(delete policy)
______ÅäÇÈ ¾ÐÃà Á¤Ã¥(compact policy)
4.1.3 ISR(In-Sync-Replicas)
______unclean.leader.election.enable
4.2 Ä«ÇÁÄ« ÇÁ·Îµà¼
4.2.1 acks ¿É¼Ç
______min.insync.replicas
4.2.2 ¸èµî¼º ÇÁ·Îµà¼(idempotence producer)
4.2.3 Æ®·£Àè¼Ç ÇÁ·Îµà¼(transaction producer)
4.3 Ä«ÇÁÄ« ÄÁ½´¸Ó
4.3.1 ¸ÖƼ ½º·¹µå ÄÁ½´¸Ó
______Ä«ÇÁÄ« ÄÁ½´¸Ó ¸ÖƼ ¿öÄ¿ ½º·¹µå Àü·«
______Ä«ÇÁÄ« ÄÁ½´¸Ó ¸ÖƼ ½º·¹µå Àü·«
4.3.2 ÄÁ½´¸Ó ·¢
______Ä«ÇÁÄ« ¸í·É¾î¸¦ »ç¿ëÇÏ¿© ÄÁ½´¸Ó ·¢ Á¶È¸
______ÄÁ½´¸Ó metrics( ) ¸Þ¼µå¸¦ »ç¿ëÇÏ¿© ÄÁ½´¸Ó ·¢ Á¶È¸
______¿ÜºÎ ¸ð´ÏÅ͸µ ÅøÀ» »ç¿ëÇÏ¿© ÄÁ½´¸Ó ·¢ Á¶È¸
4.3.2.1 Ä«ÇÁÄ« ¹ö·Î¿ì
______ÄÁ½´¸Ó ·¢ ¸ð´ÏÅ͸µ ¾ÆÅ°ÅØó
4.3.3 ÄÁ½´¸Ó ¹èÆ÷ ÇÁ·Î¼¼½º
______Áß´Ü ¹èÆ÷
______¹«Áß´Ü ¹èÆ÷
4.4 ½ºÇÁ¸µ Ä«ÇÁÄ«
4.4.1 ½ºÇÁ¸µ Ä«ÇÁÄ« ÇÁ·Îµà¼
______±âº» Ä«ÇÁÄ« ÅÛÇø´
______Ä¿½ºÅÒ Ä«ÇÁÄ« ÅÛÇø´
4.4.2 ½ºÇÁ¸µ Ä«ÇÁÄ« ÄÁ½´¸Ó
______±âº» ¸®½º³Ê ÄÁÅ×À̳Ê
______Ä¿½ºÅÒ ¸®½º³Ê ÄÁÅ×À̳Ê
4.5 Á¤¸®
[5Àå] Ä«ÇÁÄ« ½ÇÀü ÇÁ·ÎÁ§Æ®
5.1 À¥ ÆäÀÌÁö À̺¥Æ® ÀûÀç ÆÄÀÌÇÁ¶óÀÎ »ý¼º
5.1.1 ¿ä±¸ »çÇ×
5.1.2 Á¤Ã¥ ¹× ±â´É Á¤ÀÇ
5.1.3 ±â´É ±¸Çö
5.1.4 ±â´É Å×½ºÆ®
5.1.5 »ó¿ë ÀÎÇÁ¶ó ¾ÆÅ°ÅØó
5.2 ¼¹ö ÁöÇ¥ ¼öÁý ÆÄÀÌÇÁ¶óÀÎ »ý¼º°ú Ä«ÇÁÄ« ½ºÆ®¸²Áî È°¿ë
5.2.1 ¿ä±¸ »çÇ×
5.2.2 Á¤Ã¥ ¹× ±â´É Á¤ÀÇ
5.2.3 ±â´É ±¸Çö
5.2.4 ±â´É Å×½ºÆ®
5.2.5 »ó¿ë ÀÎÇÁ¶ó ¾ÆÅ°ÅØó
5.3 ¹Ì·¯¸ÞÀÌÄ¿2¸¦ »ç¿ëÇÑ ÅäÇÈ ¹Ì·¯¸µ
5.3.1 ¿ä±¸ »çÇ×
5.3.2 ±â´É Á¤ÀÇ
5.3.3 ±â´É ±¸Çö
5.3.4 ±â´É Å×½ºÆ®
5.3.5 »ó¿ë ÀÎÇÁ¶ó ¾ÆÅ°ÅØó
5.4 Á¤¸®
[6Àå] Ŭ¶ó¿ìµå Ä«ÇÁÄ« ¼ºñ½º
6.1 ÄÁÇ÷ç¾ðÆ® Ŭ¶ó¿ìµå
6.1.1 ÄÁÇ÷ç¾ðÆ® Ŭ¶ó¿ìµå È°¿ë
6.1.1.1 Ŭ·¯½ºÅÍ »ý¼º
6.1.1.2 ÅäÇÈ »ý¼º
6.1.1.3 APIÅ° ¹ß±Þ
6.1.1.4 ÇÁ·Îµà¼ ¾ÖÇø®ÄÉÀÌ¼Ç ¿¬µ¿
6.1.1.5 ÄÁ½´¸Ó ¾ÖÇø®ÄÉÀÌ¼Ç ¿¬µ¿
6.1.1.6 Ä¿³ØÅÍ S3 ÀûÀç ÆÄÀÌÇÁ¶óÀÎ
6.1.2 ÄÁÇ÷ç¾ðÆ® Ä«ÇÁÄ« Á¤¸®
6.2 AWS MSK
6.2.1 MSK È°¿ë
6.2.1.1 Ŭ·¯½ºÅÍ »ý¼º
6.2.1.2 MSK Ŭ·¯½ºÅÍ ¿¬µ¿ ÀνºÅϽº »ý¼º
6.2.1.3 ÅäÇÈ »ý¼º
6.2.1.4 ÇÁ·Î¸ÞÅ׿콺 ¼³Ä¡ ¹× ¿¬µ¿
6.2.1.5 ±×¶óÆijª ¼³Ä¡ ¹× ¿¬µ¿
6.2.1.6 ÄÜ¼Ö ÇÁ·Îµà¼, ÄÁ½´¸Ó ¿¬µ¿
6.2.2 AWS MSK Á¤¸®
6.3 Á¤¸®
[7Àå] ºÎ·Ï
7.1 Ä«ÇÁÄ« ¼Ò½ºÄÚµå ´Ù¿î·Îµå ¹× ºÐ¼®
7.2 ·ÎÄà Å×½ºÆ®¿ë Ä«ÇÁÄ« µµÄ¿ À̹ÌÁö ½ÇÇà
1.2 ºòµ¥ÀÌÅÍ ÆÄÀÌÇÁ¶óÀο¡¼ Ä«ÇÁÄ«ÀÇ ¿ªÇÒ
1.3 µ¥ÀÌÅÍ ·¹ÀÌÅ© ¾ÆÅ°ÅØó¿Í Ä«ÇÁÄ«ÀÇ ¹Ì·¡
1.4 Á¤¸®
[2Àå] Ä«ÇÁÄ« ºü¸£°Ô ½ÃÀÛÇغ¸±â
2.1 ½Ç½À¿ë Ä«ÇÁÄ« ºê·ÎÄ¿ ¼³Ä¡
2.1.1 AWS EC2 ÀνºÅϽº ¹ß±Þ ¹× º¸¾È ¼³Á¤
2.1.2 ÀνºÅϽº¿¡ Á¢¼ÓÇϱâ
______ssh ¸í·É¾î·Î Á¢¼ÓÇϱâ
______putty·Î Á¢¼ÓÇϱâ
2.1.3 ÀνºÅϽº¿¡ ÀÚ¹Ù ¼³Ä¡
2.1.4 ÁÖÅ°ÆÛ¡¤Ä«ÇÁÄ« ºê·ÎÄ¿ ½ÇÇà
______Ä«ÇÁÄ« ºê·ÎÄ¿ Èü ¸Þ¸ð¸® ¼³Á¤
______Ä«ÇÁÄ« ºê·ÎÄ¿ ½ÇÇà ¿É¼Ç ¼³Á¤
______ÁÖÅ°ÆÛ ½ÇÇà
______Ä«ÇÁÄ« ºê·ÎÄ¿ ½ÇÇà ¹× ·Î±× È®ÀÎ
2.1.5 ·ÎÄà ÄÄÇ»ÅÍ¿¡¼ Ä«ÇÁÄ«¿Í Åë½Å È®ÀÎ
______Å×½ºÆ® ÆíÀǸ¦ À§ÇÑ hosts ¼³Á¤
2.2 Ä«ÇÁÄ« Ä¿¸Çµå ¶óÀÎ Åø
2.2.1 kafka-topics.sh
______ÅäÇÈ »ý¼º
______ÅäÇÈ ¸®½ºÆ® Á¶È¸
______ÅäÇÈ »ó¼¼ Á¶È¸
______ÅäÇÈ ¿É¼Ç ¼öÁ¤
2.2.2 kafka-console-producer.sh
2.2.3 kafka-console-consumer.sh
2.2.4 kafka-consumer-groups.sh
2.2.5 kafka-verifiable-producer, consumer.sh
2.2.6 kafka-delete-records.sh
2.3 Á¤¸®
[3Àå] Ä«ÇÁÄ« ±âº» °³³ä ¼³¸í
3.1 Ä«ÇÁÄ« ºê·ÎÄ¿ ¡¤ Ŭ·¯½ºÅÍ ¡¤ ÁÖÅ°ÆÛ
______µ¥ÀÌÅÍ ÀúÀå, Àü¼Û
______µ¥ÀÌÅÍ º¹Á¦, ½ÌÅ©
______ÄÁÆ®·Ñ·¯(controller)
______µ¥ÀÌÅÍ »èÁ¦
______ÄÁ½´¸Ó ¿ÀÇÁ¼Â ÀúÀå
______ÄÚµð³×ÀÌÅÍ(coordinator)
3.2 ÅäÇÈ°ú ÆÄƼ¼Ç
______ÅäÇÈ À̸§ Á¦¾à Á¶°Ç
______ÀÇ¹Ì ÀÖ´Â ÅäÇÈ À̸§ ÀÛ¸í ¹æ¹ý
3.3_·¹ÄÚµå
3.4 Ä«ÇÁÄ« Ŭ¶óÀ̾ðÆ®
3.4.1 ÇÁ·Îµà¼ API
______Ä«ÇÁÄ« ÇÁ·Îµà¼ ÇÁ·ÎÁ§Æ® »ý¼º
______ÇÁ·Îµà¼ Áß¿ä °³³ä
______ÇÁ·Îµà¼ ÁÖ¿ä ¿É¼Ç
______¸Þ½ÃÁö Å°¸¦ °¡Áø µ¥ÀÌÅ͸¦ Àü¼ÛÇÏ´Â ÇÁ·Îµà¼
______Ä¿½ºÅÒ ÆÄƼ¼Å³Ê¸¦ °¡Áö´Â ÇÁ·Îµà¼
______ºê·ÎÄ¿ Á¤»ó Àü¼Û ¿©ºÎ¸¦ È®ÀÎÇÏ´Â ÇÁ·Îµà¼
3.4.2 ÄÁ½´¸Ó API
______Ä«ÇÁÄ« ÄÁ½´¸Ó ÇÁ·ÎÁ§Æ® »ý¼º
______ÄÁ½´¸Ó Áß¿ä °³³ä
______ÄÁ½´¸Ó ÁÖ¿ä ¿É¼Ç
______µ¿±â ¿ÀÇÁ¼Â Ä¿¹Ô
______ºñµ¿±â ¿ÀÇÁ¼Â Ä¿¹Ô
______¸®¹ë·±½º ¸®½º³Ê¸¦ °¡Áø ÄÁ½´¸Ó
______ÆÄƼ¼Ç ÇÒ´ç ÄÁ½´¸Ó
______ÄÁ½´¸Ó¿¡ ÇÒ´çµÈ ÆÄƼ¼Ç È®ÀÎ ¹æ¹ý
______ÄÁ½´¸ÓÀÇ ¾ÈÀüÇÑ Á¾·á
3.4.3 ¾îµå¹Î API
______ºê·ÎÄ¿ Á¤º¸ Á¶È¸
______ÅäÇÈ Á¤º¸ Á¶È¸
3.5 Ä«ÇÁÄ« ½ºÆ®¸²Áî
3.5.1 ½ºÆ®¸²ÁîDSL
______KStream
______KTable
______GlobalKTable
______½ºÆ®¸²ÁîDSL ÁÖ¿ä ¿É¼Ç
______½ºÆ®¸²ÁîDSL - stream( ), to( )
______½ºÆ®¸²ÁîDSL - filter( )
______½ºÆ®¸²ÁîDSL - KTable°ú KStreamÀ» join( )
______½ºÆ®¸²ÁîDSL - GlobalKTable°ú KStreamÀ» join( )
3.5.2 ÇÁ·Î¼¼¼ API
3.6 Ä«ÇÁÄ« Ä¿³ØÆ®
______Ä¿³ØÆ®¸¦ ½ÇÇàÇÏ´Â ¹æ¹ý
______´ÜÀÏ ¸ðµå Ä¿³ØÆ®
______ºÐ»ê ¸ðµå Ä¿³ØÆ®
3.6.1 ¼Ò½º Ä¿³ØÅÍ
______ÆÄÀÏ ¼Ò½º Ä¿³ØÅÍ ±¸Çö
3.6.2 ½ÌÅ© Ä¿³ØÅÍ
______ÆÄÀÏ ½ÌÅ© Ä¿³ØÅÍ ±¸Çö
3.7 Ä«ÇÁÄ« ¹Ì·¯¸ÞÀÌÄ¿2
3.7.1 ¹Ì·¯¸ÞÀÌÄ¿2¸¦ È°¿ëÇÑ Áö¸®Àû º¹Á¦(Geo-Replication)
3.8 Á¤¸®
[4Àå] Ä«ÇÁÄ« »ó¼¼ °³³ä ¼³¸í
4.1 ÅäÇÈ°ú ÆÄƼ¼Ç
4.1.1 ÀûÁ¤ ÆÄƼ¼Ç °³¼ö
4.1.2 ÅäÇÈ Á¤¸® Á¤Ã¥(cleanup.policy)
______ÅäÇÈ »èÁ¦ Á¤Ã¥(delete policy)
______ÅäÇÈ ¾ÐÃà Á¤Ã¥(compact policy)
4.1.3 ISR(In-Sync-Replicas)
______unclean.leader.election.enable
4.2 Ä«ÇÁÄ« ÇÁ·Îµà¼
4.2.1 acks ¿É¼Ç
______min.insync.replicas
4.2.2 ¸èµî¼º ÇÁ·Îµà¼(idempotence producer)
4.2.3 Æ®·£Àè¼Ç ÇÁ·Îµà¼(transaction producer)
4.3 Ä«ÇÁÄ« ÄÁ½´¸Ó
4.3.1 ¸ÖƼ ½º·¹µå ÄÁ½´¸Ó
______Ä«ÇÁÄ« ÄÁ½´¸Ó ¸ÖƼ ¿öÄ¿ ½º·¹µå Àü·«
______Ä«ÇÁÄ« ÄÁ½´¸Ó ¸ÖƼ ½º·¹µå Àü·«
4.3.2 ÄÁ½´¸Ó ·¢
______Ä«ÇÁÄ« ¸í·É¾î¸¦ »ç¿ëÇÏ¿© ÄÁ½´¸Ó ·¢ Á¶È¸
______ÄÁ½´¸Ó metrics( ) ¸Þ¼µå¸¦ »ç¿ëÇÏ¿© ÄÁ½´¸Ó ·¢ Á¶È¸
______¿ÜºÎ ¸ð´ÏÅ͸µ ÅøÀ» »ç¿ëÇÏ¿© ÄÁ½´¸Ó ·¢ Á¶È¸
4.3.2.1 Ä«ÇÁÄ« ¹ö·Î¿ì
______ÄÁ½´¸Ó ·¢ ¸ð´ÏÅ͸µ ¾ÆÅ°ÅØó
4.3.3 ÄÁ½´¸Ó ¹èÆ÷ ÇÁ·Î¼¼½º
______Áß´Ü ¹èÆ÷
______¹«Áß´Ü ¹èÆ÷
4.4 ½ºÇÁ¸µ Ä«ÇÁÄ«
4.4.1 ½ºÇÁ¸µ Ä«ÇÁÄ« ÇÁ·Îµà¼
______±âº» Ä«ÇÁÄ« ÅÛÇø´
______Ä¿½ºÅÒ Ä«ÇÁÄ« ÅÛÇø´
4.4.2 ½ºÇÁ¸µ Ä«ÇÁÄ« ÄÁ½´¸Ó
______±âº» ¸®½º³Ê ÄÁÅ×À̳Ê
______Ä¿½ºÅÒ ¸®½º³Ê ÄÁÅ×À̳Ê
4.5 Á¤¸®
[5Àå] Ä«ÇÁÄ« ½ÇÀü ÇÁ·ÎÁ§Æ®
5.1 À¥ ÆäÀÌÁö À̺¥Æ® ÀûÀç ÆÄÀÌÇÁ¶óÀÎ »ý¼º
5.1.1 ¿ä±¸ »çÇ×
5.1.2 Á¤Ã¥ ¹× ±â´É Á¤ÀÇ
5.1.3 ±â´É ±¸Çö
5.1.4 ±â´É Å×½ºÆ®
5.1.5 »ó¿ë ÀÎÇÁ¶ó ¾ÆÅ°ÅØó
5.2 ¼¹ö ÁöÇ¥ ¼öÁý ÆÄÀÌÇÁ¶óÀÎ »ý¼º°ú Ä«ÇÁÄ« ½ºÆ®¸²Áî È°¿ë
5.2.1 ¿ä±¸ »çÇ×
5.2.2 Á¤Ã¥ ¹× ±â´É Á¤ÀÇ
5.2.3 ±â´É ±¸Çö
5.2.4 ±â´É Å×½ºÆ®
5.2.5 »ó¿ë ÀÎÇÁ¶ó ¾ÆÅ°ÅØó
5.3 ¹Ì·¯¸ÞÀÌÄ¿2¸¦ »ç¿ëÇÑ ÅäÇÈ ¹Ì·¯¸µ
5.3.1 ¿ä±¸ »çÇ×
5.3.2 ±â´É Á¤ÀÇ
5.3.3 ±â´É ±¸Çö
5.3.4 ±â´É Å×½ºÆ®
5.3.5 »ó¿ë ÀÎÇÁ¶ó ¾ÆÅ°ÅØó
5.4 Á¤¸®
[6Àå] Ŭ¶ó¿ìµå Ä«ÇÁÄ« ¼ºñ½º
6.1 ÄÁÇ÷ç¾ðÆ® Ŭ¶ó¿ìµå
6.1.1 ÄÁÇ÷ç¾ðÆ® Ŭ¶ó¿ìµå È°¿ë
6.1.1.1 Ŭ·¯½ºÅÍ »ý¼º
6.1.1.2 ÅäÇÈ »ý¼º
6.1.1.3 APIÅ° ¹ß±Þ
6.1.1.4 ÇÁ·Îµà¼ ¾ÖÇø®ÄÉÀÌ¼Ç ¿¬µ¿
6.1.1.5 ÄÁ½´¸Ó ¾ÖÇø®ÄÉÀÌ¼Ç ¿¬µ¿
6.1.1.6 Ä¿³ØÅÍ S3 ÀûÀç ÆÄÀÌÇÁ¶óÀÎ
6.1.2 ÄÁÇ÷ç¾ðÆ® Ä«ÇÁÄ« Á¤¸®
6.2 AWS MSK
6.2.1 MSK È°¿ë
6.2.1.1 Ŭ·¯½ºÅÍ »ý¼º
6.2.1.2 MSK Ŭ·¯½ºÅÍ ¿¬µ¿ ÀνºÅϽº »ý¼º
6.2.1.3 ÅäÇÈ »ý¼º
6.2.1.4 ÇÁ·Î¸ÞÅ׿콺 ¼³Ä¡ ¹× ¿¬µ¿
6.2.1.5 ±×¶óÆijª ¼³Ä¡ ¹× ¿¬µ¿
6.2.1.6 ÄÜ¼Ö ÇÁ·Îµà¼, ÄÁ½´¸Ó ¿¬µ¿
6.2.2 AWS MSK Á¤¸®
6.3 Á¤¸®
[7Àå] ºÎ·Ï
7.1 Ä«ÇÁÄ« ¼Ò½ºÄÚµå ´Ù¿î·Îµå ¹× ºÐ¼®
7.2 ·ÎÄà Å×½ºÆ®¿ë Ä«ÇÁÄ« µµÄ¿ À̹ÌÁö ½ÇÇà