当前位置:   article > 正文

Kafka 消息转换_kafka 消息 转换

kafka 消息 转换

– Start

点击此处观看本系列配套视频


之前的例子都是发送和接收 String 消息,现在我们来看一个发送对象的例子。

package shangbo.kafka.example13;

import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.kafka.core.KafkaTemplate;

public class App {
	@SuppressWarnings({ "resource", "unchecked" })
	public static void main(String[] args) throws InterruptedException {
		ApplicationContext context = new AnnotationConfigApplicationContext(AppConfig.class);
		
		// 使用 kafkaTemplate 发送消息
		KafkaTemplate<String, User> kafkaTemplate = context.getBean(KafkaTemplate.class);

		// 异步发送
		kafkaTemplate.send("topic4", new User("1", "ShangBo"));
		kafkaTempl
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小桥流水78/article/detail/766880
推荐阅读
相关标签
  

闽ICP备14008679号