springboot2.0 kafka 收发消息_yy1209357299的博客-程序员ITS301_springboot接受kafka消息

技术标签: springboot 2.0  kafka  springBoot  

  1. pom依赖
<dependency>
		<groupId>org.springframework.kafka</groupId>
		<artifactId>spring-kafka</artifactId>
</dependency>

  1. application.properties
topic=test
spring.kafka.bootstrap-servers=kafka--ip:9092
spring.kafka.consumer.group-id=${
    spring.application.name}:${
    spring.cloud.client.ip-address}:${
    server.port}
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.LongSerializer
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.auto-offset-reset=earliest

3.发消息

@Autowired
	private KafkaTemplate<String, String> kafkaTemplate;
	@Value("${topic}")
	String topic;

	@RequestMapping(value = "/custom/bus/refresh", method = RequestMethod.POST)
	public String publish(
			@RequestParam(value = "destination", required = false) String destination,
			@RequestParam(value = "message", required = false) String message) {
    
		kafkaTemplate.send(topic,message);
		System.out.println("向主题" + topic + "发送消息" + message + "成功");
		return "event published";
	}

  1. 收消息
  @KafkaListener(topics = "test")
    public void listen(ConsumerRecord<String,String> record){
    
        //todo kafka接收消息
        String value = record.value();
        logger.info("Kafka ------=>"+value);
    }

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/yy1209357299/article/details/113726901

智能推荐

《软技能·代码之外的生存指南》读书笔记 ——健身_帅气呢杰哥的博客-程序员ITS301

文章目录健康密码健康标准卡路里让屁股离开椅子增肌完美腹肌站立式办公健康密码挑剔别人的身材,你自己管理好了吗?健身不仅是保持健康体魄的关键要素之一,也是灵活的、具有创造性的脑力活动的基础。毕竟,谁不想让自己外形迷人呢?软开人员,更应该坚信,学习让身体保持健壮和健康能让我们获益良多,因为我们的工作往往会把我们推到另一个方向上。立刻开始健身——就是现在,不是明天,也不是下周。健身能让你成为更好的软件开发人员,这就是原因。自信心比天赋更适合预测成功好身材能让你感觉良好,也能让你对能完成自己设定目标

实验题一(实现顺序表各种基本运算的算法)_数学作曲家的博客-程序员ITS301_编写一个程序,实现顺序表的各种基本运算和整体建表算法(假设顺序表的元素类型

目的:领会顺序表存储结构和掌握顺序表中各种基本运算算法设计。内容:编写一个.cpp的程序,实现顺序表的各种基本运算和整体建表算法(假设顺序表的元素类型为 Elemtype char),并在此基础上设计一个主程序,完成如下功能:(1)初始化顺序表L。(2)依次插入a,b,c,d,e元素。(3)输出顺序表L。(4)输出顺序表L的长度。(5)判断顺序表L是否为空。(6)输出顺序表L的第3个...

centos7.5安装memcached_youcijibi的博客-程序员ITS301

安装memcached需要先安装libmemcached一,安装libmemcached1,下载 : https://launchpad.net/libmemcached/+download2,安装 : tar -zxf .... cd ....  ./configure --prefix=/usr/local/related/libmemched   make &amp;amp;&amp;amp; ...

maven3.0以下引用rt包报错问题解决_弃言的博客-程序员ITS301

当使用maven版本低于3.0的时候,引用到rt包内容的时候,打包会报错的,找不到rt包 相应的引用包的时候,在pom.xml中增加下面的引用                                    maven-compiler-plugin                                                   

moectf IntroducingWeb初次尝试web_reaper0s的博客-程序员ITS301

题目:Welcome to moectfDo you know how to see the source code?http://moectf.cn/intro2web根据题目关键字“源码”,f12打开开发者模式,检索元素代码,发现Flag:-- 近在眼前moectf{Th3_firs7_th1ng_t0_do} –右键鼠标查看网页源码,发现Flag:-- 近在眼前moectf{T...

WebAPIs-day3_Rookie_wbe的博客-程序员ITS301

WebAPI-day3一、节点操作1. DOM节点 2. 查找节点2.1 优化关闭二维码案例 2.2 关闭多个二维码案例3. 增加节点4. 删除节点二、时间对象 三、综合案例 四、重绘和回流总结

随便推点

markdown语法教程_开心市民真真的博客-程序员ITS301_markdown 绿色方块命令

markdown语法教程1. 标题一级标题(#)二级标题(##)三级标题(###)四级标题(####)五级标题(#####)六级标题(######) 2. 段落格式换行(两个空格+回车)斜体(*文本*)粗体(**文本**)粗斜体(***文本***)分割线(---)删除线(~~文本~ ~)下划线(&lt;u&gt;文本&lt;/u&gt;)脚注([^文本...

Android studio软件安装及环境变量搭建_likebabyhoney的博客-程序员ITS301

前言  Android Studio的安装配置及使用篇终于来啦~废话不多说,以下针对JDK正确安装(及其环境变量配置完毕,即Java开发环境下)、Android Studio的安装,配置,以及创建工程、主题字体更换、窗口工具、布局、快捷方式等的基本使用逐一说明。回到顶部安装java  下载Java安装包(jdk,网上有很多下载地址,最好去官网下:https://www.java.com/zh_CN/),安装完后记得配置环境变量;在“系统变量”新建一个变量名为JAVA_HOME的变量,变量值为你本

chrome浏览器get请求设置header_PolarisHuster的博客-程序员ITS301_浏览器get请求带header

有时在测试后端接口时可能会用到get请求,比如下载文件接口之类的,但是浏览器在url栏中输入url地址后却没有输入header的地方,在使用chrome浏览器时就可以借助chrome的插件来达到这一目的,在chrome 网上应用店里面搜索“modify header”即可,如下图所示:最后笔者使用的是第一个插件,安装完该插件后会在右上角有如下图标:点击上面的插件,点击“选项”,操作如下所示:输入url,header名字一下header value即可...

k8s v1.10部署笔记_weixin_33725270的博客-程序员ITS301

本文是根据最近一份github上很不错的部署教程所做的验 证部署测试,不同之处在于原教程中是3节点,而这里共使用了4个节点。Github上的教程地址如下所示,推荐大家参照原作者文章进行自己的实验。在本文中遇到的一些问题,也已经反馈至github issue或讨论中,同时也有很多其他网友反馈遇到或发现的一些问题,其中大部分问题都已经在github教程中得到...

推荐文章

热门文章

相关标签