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

pom依赖

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

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";
	}

收消息

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

本文链接：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; ...

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. 删除节点二、时间对象三、综合案例四、重绘和回流总结