springboot 1.5.2 集成kafka 简单例子
添加依赖
compile("org.springframework.kafka:spring-kafka:1.1.2.RELEASE")
添加application.properties
#kafka # 指定kafka 代理地址,可以多个 spring.kafka.bootstrap-servers=192.168.59.130:9092,192.168.59.131:9092,192.168.59.132:9092 # 指定默认消费者group id spring.kafka.consumer.group-id=myGroup # 指定默认topic id spring.kafka.template.default-topic= my-replicated-topic # 指定listener 容器中的线程数,用于提高并发量 spring.kafka.listener.concurrency= 3 # 每次批量发送消息的数量 spring.kafka.producer.batch-size= 1000
configuration 启用kafka
package cn.xiaojf.today.data.kafka.configuration;import org.springframework.context.annotation.Configuration; import org.springframework.kafka.annotation.EnableKafka;/*** kafka 配置* @author xiaojf 2017/3/24 14:09*/ @Configuration @EnableKafka public class KafkaConfiguration {}
消息生产者
package cn.xiaojf.today.data.kafka.producer;import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.RecordMetadata; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.kafka.core.KafkaOperations; import org.springframework.kafka.core.KafkaTemplate; import org.springframework.kafka.support.ProducerListener; import org.springframework.stereotype.Component;/*** 消息生产者* @author xiaojf 2017/3/24 14:36*/ @Component public class MsgProducer {@Autowiredprivate KafkaTemplate<String,String> kafkaTemplate;public void send() {kafkaTemplate.send("my-replicated-topic","xiaojf");kafkaTemplate.send("my-replicated-topic","xiaojf");kafkaTemplate.metrics();kafkaTemplate.execute(new KafkaOperations.ProducerCallback<String, String, Object>() {@Overridepublic Object doInKafka(Producer<String, String> producer) {//这里可以编写kafka原生的api操作return null;}});//消息发送的监听器,用于回调返回信息kafkaTemplate.setProducerListener(new ProducerListener<String, String>() {@Overridepublic void onSuccess(String topic, Integer partition, String key, String value, RecordMetadata recordMetadata) {}@Overridepublic void onError(String topic, Integer partition, String key, String value, Exception exception) {}@Overridepublic boolean isInterestedInSuccess() {return false;}});} }
消息消费者
package cn.xiaojf.today.data.kafka.consumer;import org.springframework.kafka.annotation.KafkaListener; import org.springframework.stereotype.Component;/*** 消息消费者* @author xiaojf 2017/3/24 14:36*/ @Component public class MsgConsumer {@KafkaListener(topics = {"my-replicated-topic","my-replicated-topic2"})public void processMessage(String content) {System.out.println(content);}}
转载于:https://www.cnblogs.com/xiaojf/p/6613559.html
springboot 1.5.2 集成kafka 简单例子相关推荐
- SpringBoot集成Kafka简单应用
一.pom文件引入kafka所需jar包 <!--kafka支持--> <dependency><groupId>org.springframework.kafka ...
- 最简单的SpringCloudStream集成Kafka教程
开发中,服务与服务之间通信通常会用到消息中间件,如果我们使用了某一个MQ,那么消息中间件与我们的系统算是高耦合.将来有一天,要替换成另外的MQ,我们的改动就会比较大.为了解决这个问题,我们可以使用Sp ...
- SpringBoot笔记:SpringBoot2.3集成Kafka组件配置
文章目录 说明 Springboot集成Kafka 依赖配置 配置文件yml配置 Producer生产者 Consumer消费者 测试代码 注意事项 说明 本文是接<Kafka学习:CentOS ...
- 从现在开始学 Kafka:SpringBoot 集成 Kafka,生产者与消费者示例
从现在开始学 Kafka:SpringBoot 集成 Kafka,生产者与消费者示例 前言 加依赖 生产者 加配置 生产者代码示例 消费者 加配置 消费者监听器示例 调用 关于 Serializer ...
- SpringBoot 集成 kafka,基于注解批量消费设置
网上关于SpringBoot 集成kafka的批量消费功能需要手动创建类(这篇文章不错:[弄nèng - Kafka]应用篇(三) -- Springboot整合Kafka(批量消费)_司马缸砸缸了- ...
- SpringBoot集成Kafka低版本和高版本
SpringBoot集成Kafka低版本和高版本 说明 地址 低版本SpringBoot集成Kafka代码 代码 kafka生产者配置 kafka消费者配置 发送消息给kafka的Controller ...
- SpringBoot集成kafka全面实战
本文是SpringBoot+Kafka的实战讲解,如果对kafka的架构原理还不了解的读者,建议先看一下<大白话kafka架构原理>.<秒懂kafka HA(高可用)>两篇文章 ...
- springboot集成kafka及kafka web UI的使用
springboot集成kafka application.properties spring.kafka.bootstrap-servers=CentOSA:9092,CentOSB:9092,Ce ...
- springboot 集成kafka 实现多个customer不同group
springboot正常集成kafka 这个网上很多资料都有些集成,我就不浪费太多篇幅和时间了,笔者找了篇还算很容易理解的博客,自行学习 https://blog.csdn.net/tzs_10412 ...
最新文章
- php执行跟踪_PHP使用debug_backtrace方法跟踪调试代码调用详解
- [原创] Matlab 指派问题模型代码
- 类属性的存储和this指针
- 语音特征提取: MFCC的理解
- 电脑安装了mysql,但找不到mysql服务
- 高德地图画带箭头的线_精选 | 这款充电线逆天了!一条顶三条,让其它线都“下岗”吧...
- BZOJ 3240 构造矩阵+矩阵快速幂
- HTML的主体元素(简单说明)
- 【数据预测】基于matlab斑点鬣狗算法优化BP神经网络数据预测【含Matlab 219期】
- 远程桌面凭据无法工作
- 大学生网课搜题的网站源码 附带一个免费接口
- android自定义日历代码,Android自定义日历Calender代码实现
- 海信电视怎么删除自带应用
- kubernetes 网络callico和flannel两种网络
- 南大计算机系统基础CMU‘s CSAPP——第一章
- 论文阅读: Inertia Tensor Properties in Robot Dynamics Identification: A Linear Matrix Inequality Approac
- 关于百度OCR和EasyOCR的研究记录
- KRKR基础篇(二)
- Java 生成随机码工具类 线程安全 两种方式
- 语义分割系列6-Unet++(pytorch实现)
热门文章
- python 正则表达式过滤文本中的html标签 源代码解析
- tonardo做web服务器播放大视频内存泄露问题的解决
- javascript --- event loop
- HEXA机器人荣获CES Asia2018 创新奖
- IBM收购以色列应用发现公司EZSource
- Maven学习之 仓库镜像
- SQL Server 2016 RC0 安装(超多图)
- 编译apache过程中出现如下错误及解决办法
- HTML5学习笔记简明版(4):新元素之video,audio,meter,datalist,keygen,output
- 仅用 []()+! 就足以实现几乎任意Javascript代码