spring boot集成kafka开发,发送消息,Java实现

Posted zhangphil

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了spring boot集成kafka开发,发送消息,Java实现相关的知识,希望对你有一定的参考价值。

文(1):

https://zhangphil.blog.csdn.net/article/details/123108051https://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时候,即发送一条消息:

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

以上是关于spring boot集成kafka开发,发送消息,Java实现的主要内容,如果未能解决你的问题,请参考以下文章

spring boot集成kafka开发,接收kafka消息,Java

Kafka 入门和 Spring Boot 集成

Kafka 入门和 Spring Boot 集成

Spring boot集成Kafka消息中间件

Spring boot集成Kafka消息中间件

java——spring boot集成kafka——broker主题分区副本——概念理解