SpringBoot 集成 kafka

SpringBoot 集成 kafka前言:启动zk启动kafkakafka中创建一个主题topic引入依赖:<dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId>Java代码1.创建一个生产者类Produce,这里未来方便测试使用前端传入参数的信息生产数

前言 :

  1. 启动zk
  2. 启动kafka
  3. kafka中创建一个主题topic

引入依赖:

             <dependency>
            <groupId>org.springframework.kafka</groupId>
            <artifactId>spring-kafka</artifactId>

Java 代码

1.创建一个生产者类Produce,这里未来方便测试使用前端传入参数的信息生产数据

/** * @author honor */
@RestController
@RequestMapping("/kafka")
public class KafkaProducerController { 
   
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;
    
    @RequestMapping("/send")
    public String send(String message){ 
   
        //使用kafka模板发送信息
        kafkaTemplate.send("test", message);
        return "success";
    }
}

  1. 创建一个消费类KafkaConsumer,并监听某个topic

/** * @author honor */
@Component
public class KafkaConsumer { 
   
    @KafkaListener(topics = "test")
    public void listen (ConsumerRecord<?, ?> record) throws Exception { 
   
        System.out.printf("topic = %s, offset = %d, value = %s \n", record.topic(), record.offset(), record.value());
    }
}

测试:

在这里插入图片描述
在这里插入图片描述

自此简单整合结束

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:https://bianchenghao.cn/10449.html

(0)
编程小号编程小号

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注