spring boot集成kafka开发，发送消息，Java实现（2）

Dear 丶 2023-10-01 19:54 48阅读 0赞

文（1）：

[https://zhangphil.blog.csdn.net/article/details/123108051![icon-default.png_t_M1L8][]https://zhangphil.blog.csdn.net/article/details/123108051][https_zhangphil.blog.csdn.net_article_details_123108051_icon-default.png_t_M1L8_https_zhangphil.blog.csdn.net_article_details_123108051]在文（1）基础上，实现一个简单功能：在spring程序里面，发送kafka消息，kafka控制台里面，接受消息。

kafka配置和文（1）相同。

写一个简单controller，实现功能，当用户浏览器打开/send页面后，就发送一条kafka消息：

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.kafka.core.KafkaTemplate;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class MyKafka {
        @Autowired
        private KafkaTemplate kafkaTemplate;
    
        private int count = 2022;
    
        @RequestMapping(value = "/send", method = RequestMethod.GET)
        private String sendMsg() {
            String topic = "zhangphil_demo";
            String key = "my_key";
            String data = "hello,world! " + (count++);
    
            kafkaTemplate.send(topic, key, data);
    
            return data;
        }
    }

启动spring，然后在kafka控制台使用命令方式启动在主题topic为zhangphil\_demo上接收消息：

kafka-console-consumer.bat --topic zhangphil_demo --from-beginning --bootstrap-server localhost:9092

当打开浏览器访问页面localhost:7999/send时候，即发送一条消息：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAemhhbmdwaGls_size_20_color_FFFFFF_t_70_g_se_x_16][]

发送的消息，被kafka控制台收到。

[icon-default.png_t_M1L8]: https://csdnimg.cn/release/blog_editor_html/release2.0.7/ckeditor/plugins/CsdnLink/icons/icon-default.png?t=M1L8
[https_zhangphil.blog.csdn.net_article_details_123108051_icon-default.png_t_M1L8_https_zhangphil.blog.csdn.net_article_details_123108051]: https://zhangphil.blog.csdn.net/article/details/123108051
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAemhhbmdwaGls_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/3d57ec6e8aac447e84e287d25ea861d5.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAemhhbmdwaGls,size_20,color_FFFFFF,t_70,g_se,x_16