以下是一个简单的Spring Boot Kafka发送消息的完整例子:
首先,添加Spring Boot Kafka的依赖到你的pom.xml文件:
xmlorg.springframework.boot spring-boot-starter-kafka
在application.properties文件中配置Kafka的相关属性:
properties spring.kafka.bootstrap-servers=localhost:9092 spring.kafka.consumer.group-id=test-group spring.kafka.template.default-topic=test-topic
创建一个Kafka生产者类,并注入KafkaTemplate:
java import org.springframework.beans.factory.annotation.Autowired; import org.springframework.kafka.core.KafkaTemplate; import org.springframework.stereotype.Service; @Service public class KafkaProducerService { @Autowired private KafkaTemplatekafkaTemplate; public void sendMessage(String message) { kafkaTemplate.send("test-topic", message); } }
在你的Spring Boot应用程序中,你可以调用sendMessage方法发送消息:
java @Autowired private KafkaProducerService kafkaProducerService; public static void main(String[] args) { SpringApplication.run(MyApplication.class, args); KafkaProducerService kafkaProducerService = SpringApplicationContext.getBean(KafkaProducerService.class); kafkaProducerService.sendMessage("Hello, Kafka!"); }
以上是一个简单的Spring Boot Kafka发送消息的完整例子。你可以根据自己的需求进行修改和扩展。
猜你喜欢
- 21天前(江西启动“唱游江西”计划)江西启动“唱游江西”计划
- 21天前(瑞士大酒店-自助餐怎么样)瑞意心旅,以食为先 瑞士酒店开启全新"瑞士早餐计划"
- 21天前(福朋喜来登酒店宴会厅)福朋喜来登品牌亮相北部湾城市群 阳江中心福朋喜来登酒店开业
- 21天前(甘肃文旅项目)甘肃省文旅产业链招商引资推介会在天水成功举办
- 21天前(甘肃文化旅游宣传片)甘肃文旅推介走进重庆
- 21天前(澳涞山庄见证北欧零碳到中国实践,世界十佳环境保护城市榜单发布)澳涞山庄见证北欧零碳到中国实践,世界十佳环境保护城市榜单发布
- 21天前(安岚度假村及酒店推出"山海之约"目的地婚礼计划)安岚度假村及酒店推出"山海之约"目的地婚礼计划
- 21天前(天津四季酒店开业时间)天津四季酒店邀你开启灿烂暑假
- 21天前(美诺酒店集团旗下臻选品牌m collection)美诺酒店集团启动盛橡品牌战略焕新 开启全球扩张新篇章
- 21天前(殷建祥简历)全国十大牛商解码:殷建祥如何用178天技术突围打造星空梦星空房
网友评论
- 搜索
- 最新文章
- (2020广州车展哈弗)你的猛龙 独一无二 哈弗猛龙广州车展闪耀登场
- (哈弗新能源suv2019款)智能科技颠覆出行体验 哈弗重塑新能源越野SUV价值认知
- (2021款全新哈弗h5自动四驱报价)新哈弗H5再赴保障之旅,无惧冰雪护航哈弗全民电四驱挑战赛
- (海南航空现况怎样)用一场直播找到市场扩张新渠道,海南航空做对了什么?
- (visa jcb 日本)优惠面面俱到 JCB信用卡邀您畅玩日本冰雪季
- (第三届“堡里有年味·回村过大年”民俗花灯会活动)第三届“堡里有年味·回村过大年”民俗花灯会活动
- (展示非遗魅力 长安启源助力铜梁龙舞出征)展示非遗魅力 长安启源助力铜梁龙舞出征
- (阿斯塔纳航空公司)阿斯塔纳航空机队飞机数量增至50架
- (北京香港航班动态查询)香港快运航空北京大兴新航线今日首航
- (我在港航“呵护”飞机 每一次安全着陆就是最好的荣誉)我在港航“呵护”飞机 每一次安全着陆就是最好的荣誉
- 热门文章