S
S
Spring Boot参考指南
搜索
⌃K
Introduction
I. Spring Boot文档
II. 开始
III. 使用Spring Boot
IV. Spring Boot特性
23. SpringApplication
24.外化配置
25. Profiles
26. 日志
27. 开发Web应用
28. 安全
29. 使用SQL数据库
30. 使用NoSQL技术
31. 缓存
32. 消息
32.1. JMS
32.2 AMQP
32.3 Apache Kafka支持
32.3.1 发送消息
32.3.2 接收消息
32.3.3 其它的Kafka属性
33. 使用RestTemplate调用REST服务
34. 使用WebClient调用REST服务
35. 验证
36. 发送邮件
37. 使用JTA处理分布式事务
38. Hazelcast
39. Quartz调度器
40. Spring集成
41. Spring Session
42. 基于JMX的监控和管理
43. 测试
44. WebSockets
45. Web Services
46. 创建自己的自动配置
47. Kotlin支持
48. 接下来阅读什么
V. Spring Boot执行器:用于生产环境的特性
VI. 部署到云端
VII. Spring Boot CLI
VIII. 构建工具插件
IX. How-to指南
X.附录
由 GitBook 提供支持

32.3.1 发送消息

Spring的KafkaTemplate会自动配置。你可以直接在你自己的bean里面自动装配它。如下所示:
@Component
public class MyBean {
​
private final KafkaTemplate kafkaTemplate;
​
@Autowired
public MyBean(KafkaTemplate kafkaTemplate) {
this.kafkaTemplate = kafkaTemplate;
}
​
// ...
​
}
注 如果定义了RecordMessageConverter bean,它会自动关联到自动配置好的KafkaTemplate。
以前
32.3 Apache Kafka支持
下一个
32.3.2 接收消息
最近更新 3yr ago
复制链接