Kafka中怎么通过整合SpringBoot实现消息发送与消费

Kafka中怎么通过整合SpringBoot实现消息发送与消费

　　 Kafka中怎么通过整合SpringBoot实现消息发送与消费，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。

　　 为了方便测试发送消息，使用了Spring的定时任务，在类上使用EnableScheng 注解开启定时任务，通过Scheduled注解指定发送消息规则。

　　 至此，Spring Boot整合Spring Kafka消息生产者应用已经整合完毕。启动zookeeper、kafka各个服务器。启动生产者应用，查看消息生产者应用控制台日志，显示发送消息成功！说明整合OK。

　　 注意，这是使用Spring-Kafka时一定要注意版本问题，否则会报各种奇葩错误。Spri北京群发短信接口站上给出了SpringKafka和kafka-client版本它的版本号要和kafka服务器的版本保持一致的对应关系：

　　 通过使用KafkaListener来注解一个方法Spring Kafka会自动创建一个消息容器。使用该注解，并指定要消费的topic也可以指定消费组以及分区号，支持正则表达式匹配，这样，消费者一旦启动，就会监听kafka服务器上的topic，实时进行消费消息。

　　 消费者应用已经完成，接下来让我们验证Spring Kafka消息发送和接收效果。先依次启动zookeeper、kafka服务器，然后在启动生产者(短信通接口)应用，再启动消费者(k21短信api接口)应用，然后观察生产者和消费者启动类日志： 显示接受消息成功！

　　 看完上述内容，你们掌握Kafka中怎么通过整合SpringBoot实现消息发送与消费的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎亿速云行业资讯频道，感谢各位的阅读！