Spring整合Kafka

一、引入依赖

<!--Spring整合Kafka的依赖-->
<dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId>
</dependency>

二、配置kafka

#KafkaProperties
##配端口号
spring.kafka.bootstrap-servers=localhost:9092
##配消费者的组id
spring.kafka.consumer.group-id=community-consumer-group
##是否自动提交 消费者的偏移量
spring.kafka.consumer.enable-auto-commit=true
##自动提交的频率，也就是多久提交一次——3000ms-3s
spring.kafka.consumer.auto-commit-interval=3000

其中：
需进行改动（改不改无所谓）

→

三、测试代码–如何用kafka

先启动zookeeper和kafka

重点：生产者发消息，使我们主动去调的；消费者接收消息，是自动的，只需要在方法上加一个@KafkaListener(topics = {“xxxx”})，就能监听xxxx主体的生产者发来的消息，并且接收到！

3.1 KafkaTests

@RunWith(SpringRunner.class)
@SpringBootTest
@ContextConfiguration(classes = CommunityApplication.class)
public class KafkaTests {@Autowiredprivate kafkaProducer kafkaProducer;@Testpublic void testKafka(){kafkaProducer.sendMessage("test","你好！");kafkaProducer.sendMessage("test","你收到信息了吗？");try {Thread.sleep(1000*10);} catch (InterruptedException e) {e.printStackTrace();}}
}//为了方便，直接在这写两个类，而不去去外面重新新建
@Component
class kafkaProducer{//生产者@Autowiredprivate KafkaTemplate kafkaTemplate;public void sendMessage(String topic,String context){kafkaTemplate.send(topic,context);}
}@Component
class kafkaConsumer{//消费者@KafkaListener(topics = {"test"})public void handleMessage(ConsumerRecord record){System.out.println(record.value());}}

3.2 测试结果

Spring整合Kafka相关推荐

【基于注解方式】Spring整合Kafka
文章目录 1. 添加Maven依赖 2. 配置与参数分离 3. 工具类度内容 4. Producer 消息生产者配置 5. Consumer 消息消费者配置 6. 使用注解监听消息 7. 请求测试 8 ...
spring整合kafka项目生产和消费测试结果记录（一）
使用spring+springMVC+mybatis+kafka做了两个web项目,一个是生产者,一个是消费者. 通过JMeter测试工具模拟100个用户并发访问生产者项目,发送json数据给生产者的 ...
多线程高并发，spring整合kafka消费
为了更好的梳理相关知识,咱们先看纯手绘知识体系图 1.1 Kafka知识体系大纲由于我手绘这些知识体系大纲是用的xmind软件,无法上传,所以都以截图的形式展示,细节处不清楚(毕竟图片形式有限) 1 ...
【基于XML方式】Spring整合Kafka
文章目录 1.引入Maven依赖 2. kafka.properties文件中配置内容 3. 发送端 producer-kafka.xml 配置 4. 接收端 consumer-kafka.xml 配 ...
玩转Kafka—SpringGo整合Kafka
玩转Kafka-Spring整合Kafka 1 新建Spring Boot项目,增加依赖 <dependencies><dependency><groupId>or ...
kafka专题：kafka单机和集群安装详情，Spring Boot如何整合Kafka
文章目录 1. kafka单机安装 1.1 server.properties核心配置 2. kafka集群安装 2.1 kafka集群可视化界面 3. springboot如何整合kafka 4. ...
spring boot 2.x 系列 —— spring boot 整合 kafka
文章目录一.kafka的相关概念: 1.主题和分区 2.分区复制 3. 生产者 4. 消费者 5.broker和集群二.项目说明 1.1 项目结构说明 1.2 主要依赖二. 整合 kafka 2 ...
Spring Boot 整合——Spring Boot整合kafka整合
Spring Boot 整合之前的内容项目名称描述地址 base-data-mybatis 整合mybatis-plus(实际上官方教程已经很多,只做了自定义插件) 未完成 base-jpa J ...
SpringBoot实战(十四)之整合KafKa
本人今天上午参考了不少博文,发现不少博文不是特别好,不是因为依赖冲突问题就是因为版本问题. 于是我结合相关的博文和案例,自己改写了下并参考了下,于是就有了这篇文章.希望能够给大家帮助,少走一些弯路. ...

Spring整合Kafka

文章目录

Spring整合Kafka

一、引入依赖

二、配置kafka

三、测试代码–如何用kafka

3.1 KafkaTests

3.2 测试结果

Spring整合Kafka相关推荐

最新文章

热门文章