{"id":90,"date":"2023-12-02T14:47:01","date_gmt":"2023-12-02T19:47:01","guid":{"rendered":"https:\/\/coding101.xyz\/?p=90"},"modified":"2023-12-02T19:57:08","modified_gmt":"2023-12-03T00:57:08","slug":"kafka-spring","status":"publish","type":"post","link":"https:\/\/coding101.xyz\/?p=90","title":{"rendered":"Kafka Spring"},"content":{"rendered":"\n

This shows how to create Kafka with Spring integration<\/p>\n\n\n\n\n\n\n\n

First, the full maven configuration file: <\/p>\n\n\n\n

 1\n 2\n 3\n 4\n 5\n 6\n 7\n 8\n 9\n10\n11\n12\n13\n14\n15\n16\n17\n18\n19\n20\n21\n22\n23\n24\n25\n26\n27\n28\n29\n30\n31\n32\n33\n34\n35\n36\n37\n38\n39\n40<\/pre><\/td>
<?xml version="1.0" encoding="UTF-8"?><\/span>\n<project<\/span> xmlns=<\/span>"http:\/\/maven.apache.org\/POM\/4.0.0"<\/span> xmlns:xsi=<\/span>"http:\/\/www.w3.org\/2001\/XMLSchema-instance"<\/span>\nxsi:schemaLocation=<\/span>"http:\/\/maven.apache.org\/POM\/4.0.0 https:\/\/maven.apache.org\/xsd\/maven-4.0.0.xsd"<\/span>><\/span>\n<modelVersion><\/span>4.0.0<\/modelVersion><\/span>\n<parent><\/span>\n<groupId><\/span>org.springframework.boot<\/groupId><\/span>\n<artifactId><\/span>spring-boot-starter-parent<\/artifactId><\/span>\n<version><\/span>3.2.0<\/version><\/span>\n<relativePath\/><\/span> <!-- lookup parent from repository --><\/span>\n<\/parent><\/span>\n<groupId><\/span>com.prod1<\/groupId><\/span>\n<artifactId><\/span>appl<\/artifactId><\/span>\n<version><\/span>0.0.1-SNAPSHOT<\/version><\/span>\n<name><\/span>appl<\/name><\/span>\n<description><\/span>Demo project for Spring Boot<\/description><\/span>\n<properties><\/span>\n<java.version><\/span>17<\/java.version><\/span>\n<\/properties><\/span>\n<dependencies><\/span>\n<dependency><\/span>\n<groupId><\/span>org.springframework.boot<\/groupId><\/span>\n<artifactId><\/span>spring-boot-starter-web<\/artifactId><\/span>\n<\/dependency><\/span>\n<dependency><\/span>\n<groupId><\/span>org.springframework.kafka<\/groupId><\/span>\n<artifactId><\/span>spring-kafka<\/artifactId><\/span>\n<\/dependency><\/span>\n\n<\/dependencies><\/span>\n\n<build><\/span>\n<plugins><\/span>\n<plugin><\/span>\n<groupId><\/span>org.springframework.boot<\/groupId><\/span>\n<artifactId><\/span>spring-boot-maven-plugin<\/artifactId><\/span>\n<\/plugin><\/span>\n<\/plugins><\/span>\n<\/build><\/span>\n\n<\/project><\/span>\n<\/pre><\/td><\/tr><\/table><\/div>\n\n\n\n
Configuration<\/h2>\n\n\n\n
The code configures some beans that allow creation of a KafkaTemplate for sending message and gives an example of how a listener is created with a simple annotation<\/p>\n\n\n\n
 1\n 2\n 3\n 4\n 5\n 6\n 7\n 8\n 9\n10\n11\n12\n13\n14\n15\n16\n17\n18\n19\n20\n21\n22\n23\n24\n25\n26\n27\n28\n29\n30\n31\n32\n33\n34\n35\n36\n37\n38\n39<\/pre><\/td>
package<\/span> com.<\/span>prod1<\/span>.<\/span>appl<\/span>;<\/span>\n\nimport<\/span> org.apache.kafka.clients.producer.ProducerConfig<\/span>;<\/span>\nimport<\/span> org.apache.kafka.common.serialization.StringSerializer<\/span>;<\/span>\nimport<\/span> org.springframework.context.annotation.Bean<\/span>;<\/span>\nimport<\/span> org.springframework.context.annotation.Configuration<\/span>;<\/span>\nimport<\/span> org.springframework.kafka.annotation.KafkaListener<\/span>;<\/span>\nimport<\/span> org.springframework.kafka.core.DefaultKafkaProducerFactory<\/span>;<\/span>\nimport<\/span> org.springframework.kafka.core.KafkaTemplate<\/span>;<\/span>\nimport<\/span> org.springframework.kafka.core.ProducerFactory<\/span>;<\/span>\n\nimport<\/span> java.util.HashMap<\/span>;<\/span>\nimport<\/span> java.util.Map<\/span>;<\/span>\n\n@Configuration<\/span>\npublic<\/span> class<\/span> KafkaConfig<\/span> {<\/span>\n    @Bean<\/span>\n    public<\/span> KafkaTemplate<<\/span>String,<\/span> String><\/span> kafkaTemplate()<\/span> {<\/span>\n        return<\/span> new<\/span> KafkaTemplate<\/span>(<\/span>prodFactory());<\/span>\n    }<\/span>\n\n    @Bean<\/span>\n    public<\/span> ProducerFactory<<\/span>String,<\/span> String><\/span> prodFactory()<\/span> {<\/span>\n        Map<<\/span>String,<\/span> Object><\/span> props =<\/span> new<\/span> HashMap <>();<\/span>\n        props.<\/span>put<\/span>(<\/span>ProducerConfig.<\/span>BOOTSTRAP_SERVERS_CONFIG<\/span>,<\/span> "localhost:9092"<\/span>);<\/span>\n        props.<\/span>put<\/span>(<\/span>ProducerConfig.<\/span>KEY_SERIALIZER_CLASS_CONFIG<\/span>,<\/span> StringSerializer.<\/span>class<\/span>);<\/span>\n        props.<\/span>put<\/span>(<\/span>ProducerConfig.<\/span>VALUE_SERIALIZER_CLASS_CONFIG<\/span>,<\/span> StringSerializer.<\/span>class<\/span>);<\/span>\n\n        DefaultKafkaProducerFactory<<\/span>String,<\/span> String><\/span> prodFactory =<\/span> new<\/span> DefaultKafkaProducerFactory<>(<\/span>props);<\/span>\n\n        return<\/span> prodFactory;<\/span>\n    }<\/span>\n\n    @KafkaListener<\/span>(<\/span>topics =<\/span> "tester1"<\/span>,<\/span> groupId =<\/span> "tester"<\/span>)<\/span>\n    public<\/span> void<\/span> listen<\/span>(<\/span>String message)<\/span> {<\/span>\n        System.<\/span>out<\/span>.<\/span>println<\/span>(<\/span>"msg: "<\/span> +<\/span> message);<\/span>\n    }<\/span>\n\n}<\/span>\n<\/pre><\/td><\/tr><\/table><\/div>\n","protected":false},"excerpt":{"rendered":"
This shows how to create Kafka with Spring integration<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-90","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"_links":{"self":[{"href":"https:\/\/coding101.xyz\/index.php?rest_route=\/wp\/v2\/posts\/90","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/coding101.xyz\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/coding101.xyz\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/coding101.xyz\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/coding101.xyz\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=90"}],"version-history":[{"count":2,"href":"https:\/\/coding101.xyz\/index.php?rest_route=\/wp\/v2\/posts\/90\/revisions"}],"predecessor-version":[{"id":92,"href":"https:\/\/coding101.xyz\/index.php?rest_route=\/wp\/v2\/posts\/90\/revisions\/92"}],"wp:attachment":[{"href":"https:\/\/coding101.xyz\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=90"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/coding101.xyz\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=90"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/coding101.xyz\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=90"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}