{"id":2251,"date":"2021-07-17T15:22:43","date_gmt":"2021-07-17T06:22:43","guid":{"rendered":"https:\/\/www.skyer9.pe.kr\/wordpress\/?p=2251"},"modified":"2022-04-18T16:06:39","modified_gmt":"2022-04-18T07:06:39","slug":"kafka-%eb%a5%bc-%ec%9d%b4%ec%9a%a9%ed%95%9c-%eb%a9%94%ec%8b%9c%ec%a7%95","status":"publish","type":"post","link":"https:\/\/www.skyer9.pe.kr\/wordpress\/?p=2251","title":{"rendered":"Spring Kafka \ub97c \uc774\uc6a9\ud55c \uba54\uc2dc\uc9d5(send\/receive message)"},"content":{"rendered":"

Spring Kafka \ub97c \uc774\uc6a9\ud55c \uba54\uc2dc\uc9d5(send\/receive message)<\/h1>\n

\ubaa9\ud45c<\/h2>\n

Kafka \ub97c \uc774\uc6a9\ud574, \uba54\uc2dc\uc9d5 \uc2dc\uc2a4\ud15c\uc744 \uad6c\uc131\ud569\ub2c8\ub2e4.<\/p>\n

Kafka \uc124\uce58<\/h2>\n

Install Kafka on Windows<\/a>, Install Kafka with docker<\/a> \ub97c \ucc38\uc870\ud574\uc11c Kafka \ub97c \uc124\uce58\ud569\ub2c8\ub2e4.<\/p>\n

\ud504\ub85c\uc81d\ud2b8 \uc0dd\uc131<\/h2>\n

\uc2e0\uaddc \ud504\ub85c\uc81d\ud2b8\ub97c \uc0dd\uc131\ud569\ub2c8\ub2e4.<\/p>\n

\uc758\uc874\uc131\uc740 DevTools, Lombok, Web, Spring for Apache Kafka \ub97c \uc120\ud0dd\ud569\ub2c8\ub2e4.<\/p>\n

application.yml \uc218\uc815<\/h2>\n
spring:\n  kafka:\n    consumer:\n      bootstrap-servers: 127.0.0.1:9092\n      group-id: foo\n      # auto-offset-reset: earliest\n      # key-deserializer: org.apache.kafka.common.serialization.StringDeserializer\n      # value-deserializer: org.apache.kafka.common.serialization.StringDeserializer\n    producer:\n      bootstrap-servers: 127.0.0.1:9092\n      # key-serializer: org.apache.kafka.common.serialization.StringSerializer\n      # value-serializer: org.apache.kafka.common.serialization.StringSerializer<\/code><\/pre>\n
Producer \uc0dd\uc131<\/h2>\n
@Service\npublic class KafkaProducer {\n\n    private static final String TOPIC = "exam";\n    private final KafkaTemplate<String, String> kafkaTemplate;\n\n    @Autowired\n    public KafkaProducer(KafkaTemplate kafkaTemplate) {\n        this.kafkaTemplate = kafkaTemplate;\n    }\n\n    public void sendMessage(String message) {\n        System.out.printf("Produce message : %s%n", message);\n        this.kafkaTemplate.send(TOPIC, message);\n    }\n}<\/code><\/pre>\n
Consumer \uc0dd\uc131<\/h2>\n
@Service\npublic class KafkaConsumer {\n\n    @KafkaListener(topics = "exam", groupId = "foo")\n    public void consume(String message) throws IOException {\n        System.out.printf("Consumed message : %s%n", message);\n    }\n}<\/code><\/pre>\n
Controller \uc0dd\uc131<\/h2>\n
@RestController\n@RequestMapping(value = "\/kafka")\npublic class KafkaController {\n\n    private final KafkaProducer producer;\n\n    @Autowired\n    KafkaController(KafkaProducer producer) {\n        this.producer = producer;\n    }\n\n    @GetMapping("\/")\n    public String sendMessage(@RequestParam("message") String message) {\n        this.producer.sendMessage(message);\n\n        return "success";\n    }\n}<\/code><\/pre>\n
\ud504\ub85c\uc81d\ud2b8 \uc2e4\ud589<\/h2>\n
\ud504\ub85c\uc81d\ud2b8 \uc2e4\ud589 \ud6c4 \uc544\ub798 \ub9c1\ud06c\uc5d0 \uc811\uc18d\ud569\ub2c8\ub2e4.<\/p>\n
http:\/\/localhost:8080\/kafka\/?message=\ud558\uc774<\/a><\/p>\n
\ub85c\uadf8\uc5d0 \uba54\uc2dc\uc9c0\uac00 \ucd9c\ub825\ub418\ub294 \uac83\uc744 \ud655\uc778\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4.<\/p>\n
json \ub370\uc774\ud0c0 \uc1a1\uc218\uc2e0\ud558\uae30<\/h2>\n
build.gradle<\/p>\n
......\n    implementation 'org.json:json:20220320'\n    implementation 'com.googlecode.json-simple:json-simple:1.1.1'\n......<\/code><\/pre>\n
    public void sendMessage(String message) {\n        System.out.printf("Produce message : %s%n", message);\n\n        Date now = new Date();\n        DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); \/\/yyyy-MM-dd HH:mm:ss\n        System.out.println(df.format(now));\n\n        JSONObject data = new JSONObject();\n        data.put("dt", df.format(now));\n        data.put("msg", message);\n\n        System.out.printf("Produce json message : %s%n", data.toJSONString());\n        this.kafkaTemplate.send(TOPIC, data.toJSONString());\n    }<\/code><\/pre>\n
    @KafkaListener(topics = "json_topic", groupId = "foo")\n    public void consume(String message) {\n        System.out.printf("Consumed json message : %s%n", message);\n\n        try {\n            JSONParser parser = new JSONParser();\n            Object obj = parser.parse(message);\n            JSONObject jsonObj = (JSONObject) obj;\n\n            String msg = (String) jsonObj.get("msg");\n            System.out.printf("Consumed message : %s%n", msg);\n        } catch (ParseException ignored) {\n            \/\/\n        }\n    }<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"
Spring Kafka \ub97c \uc774\uc6a9\ud55c \uba54\uc2dc\uc9d5(send\/receive message) \ubaa9\ud45c Kafka \ub97c \uc774\uc6a9\ud574, \uba54\uc2dc\uc9d5 \uc2dc\uc2a4\ud15c\uc744 \uad6c\uc131\ud569\ub2c8\ub2e4. Kafka \uc124\uce58 Install Kafka on Windows, Install Kafka with docker \ub97c \ucc38\uc870\ud574\uc11c Kafka \ub97c \uc124\uce58\ud569\ub2c8\ub2e4. \ud504\ub85c\uc81d\ud2b8 \uc0dd\uc131 \uc2e0\uaddc \ud504\ub85c\uc81d\ud2b8\ub97c \uc0dd\uc131\ud569\ub2c8\ub2e4. \uc758\uc874\uc131\uc740 DevTools, Lombok, Web, Spring for Apache Kafka \ub97c \uc120\ud0dd\ud569\ub2c8\ub2e4. application.yml \uc218\uc815 spring: kafka: consumer: bootstrap-servers: 127.0.0.1:9092 group-id: foo # auto-offset-reset: earliest\u2026 Read More »<\/a><\/span><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[29],"tags":[],"class_list":["post-2251","post","type-post","status-publish","format-standard","hentry","category-spring-boot-2-5"],"_links":{"self":[{"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/2251","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=2251"}],"version-history":[{"count":4,"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/2251\/revisions"}],"predecessor-version":[{"id":5284,"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/2251\/revisions\/5284"}],"wp:attachment":[{"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=2251"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=2251"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.skyer9.pe.kr\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=2251"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}