kafka使用

框架: spring-kafka 1.2.2

生产者端代码

说明:

bootstrapServers: kafka 地址

kafkaTemplate: 服务调用模板

消费端代码:

说明:

@EnableKafka : 开启kafka

bootstrapServers: kafka 地址

groupIdConfig: 群组名称

consumerConfigs(): 客户端配置

consumerFactory():客户端工厂

kafkaListenerContainerFactory(): 配置kafka监听工厂

实际使用:

发送消息:


指定话题和内容,框架会发送到对应的话题

接收消息:

使用

@KafkaListener 注解并加上对应的话题,就可以自动接收相应的消息

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,408评论 19 139
  • kafka的定义:是一个分布式消息系统,由LinkedIn使用Scala编写,用作LinkedIn的活动流(Act...
    时待吾阅读 10,746评论 1 15
  • Android 自定义View的各种姿势1 Activity的显示之ViewRootImpl详解 Activity...
    passiontim阅读 175,491评论 25 709
  • 翻遍了ss的微博,我可能脑子有病
    拧螺丝的小姑娘阅读 1,027评论 0 0
  • 《朱子治家格言》起句便是:黎明即起,洒扫庭除,要内外整洁。 昨夜宿醉,但历年养就的生物钟,使我自然而然的在七点钟就...
    宜寿东木阅读 4,145评论 2 6