{"id":35132,"date":"2023-05-28T11:30:26","date_gmt":"2023-05-28T02:30:26","guid":{"rendered":"https:\/\/m9js.shop\/blog\/?p=35132"},"modified":"2023-05-28T11:30:26","modified_gmt":"2023-05-28T02:30:26","slug":"advanced-stream-processing-with-spring-cloud-stream-and-apache-kafka-streams","status":"publish","type":"post","link":"https:\/\/m9js.shop\/blog\/development\/advanced-stream-processing-with-spring-cloud-stream-and-apache-kafka-streams","title":{"rendered":"Advanced Stream Processing with Spring Cloud Stream and Apache Kafka Streams"},"content":{"rendered":"

\uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc73c\ub85c\uc758 \uace0\uae09 \uc2a4\ud2b8\ub9bc \ucc98\ub9ac<\/strong><\/h1>\n

\uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc740 \ub300\uc6a9\ub7c9 \ub370\uc774\ud130 \ucc98\ub9ac\ub97c \uc704\ud55c \ub450 \uac00\uc9c0 \uc778\uae30 \uc788\ub294 \uc624\ud508 \uc18c\uc2a4 \uc635\uc158\uc785\ub2c8\ub2e4. \uc774 \ub450 \uae30\uc220\uc744 \uacb0\ud569\ud558\uba74 \ub300\uaddc\ubaa8 \ub370\uc774\ud130 \ucc98\ub9ac\ub97c \uc704\ud55c \uace0\uae09 \uc2a4\ud2b8\ub9bc \ucc98\ub9ac\ub97c \uad6c\ud604\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4.<\/p>\n

\uc774\ubc88 \uae00\uc5d0\uc11c\ub294 \uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc73c\ub85c\uc758 \uace0\uae09 \uc2a4\ud2b8\ub9bc \ucc98\ub9ac\uc5d0 \ub300\ud574 \uc0b4\ud3b4\ubcf4\uaca0\uc2b5\ub2c8\ub2e4. \uba3c\uc800 \ub450 \uae30\uc220\uc758 \uc544\ud0a4\ud14d\ucc98\ub97c \ube44\uad50\ud558\uace0, \uadf8 \ub2e4\uc74c\uc5d0 \ub300\ub7c9 \ub370\uc774\ud130 \ucc98\ub9ac \ubc29\ubc95\uc744 \uc54c\uc544\ubcf4\uaca0\uc2b5\ub2c8\ub2e4.<\/p>\n

\uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc758 \uc544\ud0a4\ud14d\ucc98 \ube44\uad50<\/strong><\/h2>\n

\uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uc740 \uc2a4\ud504\ub9c1 \ubd80\ud2b8\uc640 \uc2a4\ud504\ub9c1 \uc0dd\ud0dc\uacc4\uc758 \ub2e4\uc591\ud55c \uae30\uc220\uc744 \ud65c\uc6a9\ud558\uc5ec \ud074\ub77c\uc6b0\ub4dc \ub124\uc774\ud2f0\ube0c \uc560\ud50c\ub9ac\ucf00\uc774\uc158 \uac1c\ubc1c\uc744 \uc704\ud55c \ub9c8\uc774\ud06c\ub85c\uc11c\ube44\uc2a4 \uc544\ud0a4\ud14d\ucc98\ub97c \uad6c\ud604\ud558\ub294 \ub370 \uc0ac\uc6a9\ub429\ub2c8\ub2e4. \uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uc740 \uc774\ub7ec\ud55c \ub9c8\uc774\ud06c\ub85c\uc11c\ube44\uc2a4 \uc544\ud0a4\ud14d\ucc98\uc5d0\uc11c \ub370\uc774\ud130 \ud1b5\ud569\uc744 \ucc98\ub9ac\ud558\ub294 \ub370 \uc911\uc810\uc744 \ub461\ub2c8\ub2e4.<\/p>\n

\ubc18\uba74\uc5d0 \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc740 \uc544\ud30c\uce58 \uce74\ud504\uce74\uc758 \uc2a4\ud2b8\ub9bc \ucc98\ub9ac \ub77c\uc774\ube0c\ub7ec\ub9ac\uc785\ub2c8\ub2e4. \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc740 \ub300\uaddc\ubaa8 \uc2a4\ud2b8\ub9bc \ucc98\ub9ac\ub97c \uc704\ud574 \uc124\uacc4\ub418\uc5c8\uc73c\uba70, \ub192\uc740 \ucc98\ub9ac\ub7c9\uacfc \ub0ae\uc740 \uc9c0\uc5f0 \uc2dc\uac04\uc744 \ubcf4\uc7a5\ud569\ub2c8\ub2e4. \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc740 \ub2e8\uc77c \ud504\ub85c\uc138\uc2a4\ub85c \uc2e4\ud589\ub418\uba70, \uc774\ub97c \ud1b5\ud574 \ub192\uc740 \ucc98\ub9ac\ub7c9\uc744 \ub2ec\uc131\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4.<\/p>\n

\uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc740 \ubaa8\ub450 \uc2a4\ud2b8\ub9bc \ucc98\ub9ac\ub97c \uc704\ud55c \ub77c\uc774\ube0c\ub7ec\ub9ac\uc774\uc9c0\ub9cc, \uac01\uac01\uc758 \uc544\ud0a4\ud14d\ucc98\ub294 \ub2e4\ub985\ub2c8\ub2e4. \uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uc740 \uc2a4\ud504\ub9c1 \uc0dd\ud0dc\uacc4\uc758 \uac1c\ub150\uacfc \uac1c\ubc1c \ubc29\ubc95\ub860\uc5d0 \ub530\ub77c \uad6c\uc131\ub418\uc5b4 \uc788\uc73c\uba70, \ub9c8\uc774\ud06c\ub85c\uc11c\ube44\uc2a4 \uc544\ud0a4\ud14d\ucc98\ub97c \uc9c0\uc6d0\ud569\ub2c8\ub2e4. \ubc18\uba74\uc5d0 \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc740 \uce74\ud504\uce74\uc758 \ub0b4\ubd80 \ub77c\uc774\ube0c\ub7ec\ub9ac\ub85c\uc11c \uac1c\ubc1c\ub418\uc5c8\uc73c\uba70, \ub300\uaddc\ubaa8 \uc2a4\ud2b8\ub9bc \ucc98\ub9ac\uc5d0 \ucd5c\uc801\ud654\ub418\uc5b4 \uc788\uc2b5\ub2c8\ub2e4.<\/p>\n

\uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc744 \ud65c\uc6a9\ud55c \ub300\ub7c9 \ub370\uc774\ud130 \ucc98\ub9ac \ubc29\ubc95<\/strong><\/h2>\n

\uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc744 \ud568\uaed8 \uc0ac\uc6a9\ud558\uba74 \ub300\uaddc\ubaa8 \ub370\uc774\ud130 \ucc98\ub9ac\ub97c \uc704\ud55c \uace0\uae09 \uc2a4\ud2b8\ub9bc \ucc98\ub9ac\ub97c \uad6c\ud604\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4. \uc774\ub97c \ud1b5\ud574 \ub300\uaddc\ubaa8 \ub370\uc774\ud130\ub97c \uc2e4\uc2dc\uac04\uc73c\ub85c \ucc98\ub9ac\ud558\uace0, \ube60\ub978 \uc751\ub2f5 \uc2dc\uac04\uacfc \ub192\uc740 \ucc98\ub9ac\ub7c9\uc744 \ubcf4\uc7a5\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4.<\/p>\n

\uc544\ub798\ub294 \uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc744 \ud65c\uc6a9\ud55c \ub300\ub7c9 \ub370\uc774\ud130 \ucc98\ub9ac \ubc29\ubc95\uc758 \uc608\uc2dc\uc785\ub2c8\ub2e4.<\/p>\n

@StreamListener(Sink.INPUT)\npublic void process(KStream input) {\n\n  KStream transformed = input\n      .mapValues(value -> value.toLowerCase())\n      .filter((key, value) -> value.contains(\"spring\"));\n\n  transformed.to(\"output-topic\");\n}<\/code><\/pre>\n
\uc704 \ucf54\ub4dc\ub294 \uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc744 \uc0ac\uc6a9\ud558\uc5ec \uc785\ub825 \ub370\uc774\ud130\ub97c \ucc98\ub9ac\ud558\ub294 \uc608\uc2dc\uc785\ub2c8\ub2e4. \uc774 \ucf54\ub4dc\ub294 "Sink.INPUT" \ud1a0\ud53d\uc5d0\uc11c \uc785\ub825 \ub370\uc774\ud130\ub97c \uc77d\uc740 \ub2e4\uc74c, \ub370\uc774\ud130\ub97c \uc18c\ubb38\uc790\ub85c \ubcc0\ud658\ud558\uace0 "spring"\uc774\ub77c\ub294 \ub2e8\uc5b4\ub97c \ud3ec\ud568\ud558\ub294 \ub370\uc774\ud130\ub9cc \ud544\ud130\ub9c1\ud558\uc5ec "output-topic" \ud1a0\ud53d\uc73c\ub85c \ucd9c\ub825\ud569\ub2c8\ub2e4.<\/p>\n
\uc774\ucc98\ub7fc \uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc744 \ud568\uaed8 \uc0ac\uc6a9\ud558\uba74 \ub300\uaddc\ubaa8 \ub370\uc774\ud130 \ucc98\ub9ac\ub97c \uc704\ud55c \uace0\uae09 \uc2a4\ud2b8\ub9bc \ucc98\ub9ac\ub97c \uad6c\ud604\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4.<\/p>\n
\uacb0\ub860<\/strong><\/h2>\n
\uc774\ubc88 \uae00\uc5d0\uc11c\ub294 \uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc73c\ub85c\uc758 \uace0\uae09 \uc2a4\ud2b8\ub9bc \ucc98\ub9ac\uc5d0 \ub300\ud574 \uc54c\uc544\ubcf4\uc558\uc2b5\ub2c8\ub2e4. \uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc740 \uac01\uac01\uc758 \uc544\ud0a4\ud14d\ucc98\uc640 \ud2b9\uc131\uc744 \uac00\uc9c0\uace0 \uc788\uc9c0\ub9cc, \ub450 \uae30\uc220\uc744 \ud568\uaed8 \uc0ac\uc6a9\ud558\uba74 \ub300\uaddc\ubaa8 \ub370\uc774\ud130 \ucc98\ub9ac\ub97c \uc704\ud55c \uace0\uae09 \uc2a4\ud2b8\ub9bc \ucc98\ub9ac\ub97c \uad6c\ud604\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4. \uc2a4\ud504\ub9c1 \ud074\ub77c\uc6b0\ub4dc \uc2a4\ud2b8\ub9bc\uacfc \uc544\ud30c\uce58 \uce74\ud504\uce74 \uc2a4\ud2b8\ub9bc\uc744 \uc0ac\uc6a9\ud558\uc5ec \ub370\uc774\ud130 \ud1b5\ud569\uacfc \ub300\uaddc\ubaa8 \ub370\uc774\ud130 \ucc98\ub9ac\ub97c \uad6c\ud604\ud574\ubcf4\uc138\uc694. <\/p>\n
\"Spring<\/p>\n","protected":false},"excerpt":{"rendered":"
Spring Cloud Stream\uc640 Apache Kafka Streams\ub97c \ud65c\uc6a9\ud55c \uace0\uae09 \uc2a4\ud2b8\ub9bc \ucc98\ub9ac\uc5d0 \ub300\ud574 \uc54c\uc544\ubcf4\uc790.<\/p>\n","protected":false},"author":1,"featured_media":12882,"comment_status":"closed","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"footnotes":""},"categories":[1957],"tags":[2453,5898,2082,2105,2112,2188,2156,5932],"class_list":["post-35132","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-development","tag-advanced","tag-backend","tag-cloud","tag-java","tag-processing","tag-public","tag-spring","tag-spring-boot"],"acf":[],"_links":{"self":[{"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/posts\/35132","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/comments?post=35132"}],"version-history":[{"count":1,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/posts\/35132\/revisions"}],"predecessor-version":[{"id":35220,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/posts\/35132\/revisions\/35220"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/media\/12882"}],"wp:attachment":[{"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/media?parent=35132"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/categories?post=35132"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/tags?post=35132"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}