SpringCloudBus使用Kafka实现消息总线

比眉伴天荒 2021-12-04 09:53 539阅读 0赞

转自： [https://blog.csdn.net/wqh8522/article/details/79193873][https_blog.csdn.net_wqh8522_article_details_79193873]

Spring Cloud构建微服务架构（七）消息总线（续：Kafka）: [http://blog.didispace.com/springcloud7-2/][http_blog.didispace.com_springcloud7-2]

spring cloud bus整合kafka问题:  [https://bbs.csdn.net/topics/392179985][https_bbs.csdn.net_topics_392179985]

springboot 2.0.0.RELEASE +spring cloud Finchley.M7 +springcloud bus+kafka实现配置动态刷新: [https://my.oschina.net/u/2263272/blog/1634010?nocache=1531813104906][https_my.oschina.net_u_2263272_blog_1634010_nocache_1531813104906]

SpringCloud消息总线BUS: [https://cloud.tencent.com/developer/news/251479][https_cloud.tencent.com_developer_news_251479]

[Spring Cloud Bus整合Kafka][Spring Cloud Bus_Kafka]: [https://segmentfault.com/a/1190000011752466][Spring Cloud Bus_Kafka]

Spring Cloud Bus 消息总线集成Kafka: [https://www.cppentry.com/bencandy.php?fid=120&id=183602][https_www.cppentry.com_bencandy.php_fid_120_id_183602]

[SpringCloud实战8-Bus消息总线][SpringCloud_8-Bus]:  [https://www.cnblogs.com/huangjuncong/p/9077099.html][SpringCloud_8-Bus]

SpringCloudBus使用Kafka实现消息总线:  [https://blog.csdn.net/wqh8522/article/details/79193873][https_blog.csdn.net_wqh8522_article_details_79193873]

[SpringCloudBus使用Kafka实现消息总线][SpringCloudBus_Kafka]: [https://segmentfault.com/a/1190000013031488][SpringCloudBus_Kafka]

[SpringCloud 分布式配置][SpringCloud]:   [https://www.cnblogs.com/zhangjianbin/p/6347247.html][SpringCloud]

spring cloud 系列第8篇 —— config+bus 分布式配置中心与配置热刷新 (F版本): [https://blog.csdn.net/m0\_37809146/article/details/86677462][https_blog.csdn.net_m0_37809146_article_details_86677462]

Spring Cloud (20) | Spring Cloud Bus 使用kafka消息总线、gitlab添加webhooks实现自动刷新配置: [https://blog.csdn.net/superdangbo/article/details/78776532][https_blog.csdn.net_superdangbo_article_details_78776532]

\[菜鸟SpringCloud实战入门\]第八章：通过消息总线Spring Cloud Bus实现配置文件刷新（使用Kafka）:  [https://blog.csdn.net/qqxx6661/article/details/88701051][https_blog.csdn.net_qqxx6661_article_details_88701051]

Spring Cloud Bus 消息总线 kafka 集成配置:  [https://blog.csdn.net/skywoodsky/article/details/80772848][https_blog.csdn.net_skywoodsky_article_details_80772848]

学习笔记:微服务-22 spring cloud config+kafka+spring cloud bus 消息总线实现配置自动更新: [https://blog.csdn.net/olinbsoft/article/details/86586467][https_blog.csdn.net_olinbsoft_article_details_86586467]

使用kafka作为springcloud bus的消息总线，以及如何自定义总线事件: [https://blog.csdn.net/xiao\_jun\_0820/article/details/78115746][https_blog.csdn.net_xiao_jun_0820_article_details_78115746]

Spring Cloud Config + Spring Cloud Bus + kafka实现配置中心配置动态更新: [https://blog.csdn.net/lixiaxin200319/article/details/82811047][https_blog.csdn.net_lixiaxin200319_article_details_82811047]

Config Server——使用Spring Cloud Bus自动刷新配置: [http://www.itmuch.com/spring-cloud/spring-cloud-bus-auto-refresh-configuration/][http_www.itmuch.com_spring-cloud_spring-cloud-bus-auto-refresh-configuration]

SpringCloud学习之SpringCloudBus: [https://yq.aliyun.com/articles/613228][https_yq.aliyun.com_articles_613228]

Spring Cloud构建微服务架构（七）消息总线（续：Kafka）: [https://www.jianshu.com/p/730d86030a41][https_www.jianshu.com_p_730d86030a41]

[spring cloud bus整合kafka问题][spring cloud bus_kafka]: [https://geekori.com/details.php?que\_id=8168][spring cloud bus_kafka]

springcloudbus自定义event消息kafka中收不到消息，springcloud Greenwich版不行，daston版本可以:  [https://ask.csdn.net/questions/761217][https_ask.csdn.net_questions_761217]

Spring Cloud Bus: [https://springcloud.cc/spring-cloud-bus.html][https_springcloud.cc_spring-cloud-bus.html]

Spring Cloud构建微服务架构（七）消息总线（续：Kafka）: [http://blog.didispace.com/springcloud7-2/][http_blog.didispace.com_springcloud7-2]

Spring Cloud构建微服务架构（七）消息总线: [http://blog.didispace.com/springcloud7/][http_blog.didispace.com_springcloud7]

\[Spring Cloud\] 6 Spring Cloud Bus :  [https://my.oschina.net/roccn/blog/832059][https_my.oschina.net_roccn_blog_832059]

jfinal-admin 3.6 正式发布，更新 jfinal 及 beetl 到最新版本: [https://www.xujun.org/article308898.html][https_www.xujun.org_article308898.html]

Flume + Kafka学习——整合Demo:  [https://www.ucloud.cn/yun/8346.html][https_www.ucloud.cn_yun_8346.html]

[Spring Cloud Alibaba系列教程-05-Sentinel入门与整合][Spring Cloud Alibaba_-05-Sentinel]:  [http://ldnmen.com/][http_ldnmen.com]

Spring Cloud 微服务分布式架构项目开发实战: [https://www.douban.com/group/topic/146012302/][https_www.douban.com_group_topic_146012302]

Spring\_Cloud构建云架构: [https://www.iteye.com/blogs/subjects/Spring-Cloud\#4370][https_www.iteye.com_blogs_subjects_Spring-Cloud_4370]

跟我学SpringCloud | 第一篇：介绍:  [http://www.hellojava.com/a/79952.html][http_www.hellojava.com_a_79952.html]

Spring Cloud笔记:  [https://www.bcoder.top/2018/12/08/SpringCloud%E7%AC%94%E8%AE%B0/][https_www.bcoder.top_2018_12_08_SpringCloud_E7_AC_94_E8_AE_B0]

Spring Cloud微服务实践:  [http://server.51cto.com/Micro-550525.htm][http_server.51cto.com_Micro-550525.htm]

Spring Cloud Stream kafka在集群时候遇到的消息重复消费问题:  [http://www.spring4all.com/article/773][http_www.spring4all.com_article_773]

[mhuang][] / [mhuang-cloud-study][]:   [https://gitee.com/mhuang/mhuang-cloud-study][mhuang-cloud-study]

Spring cloud实践之道四（消息处理）: [http://www.imooc.com/article/275387][http_www.imooc.com_article_275387]

Spring Cloud 入门教程(七): 消息总线(Spring Cloud Bus)(Greenwich.RELEASE):  [https://www.liangzl.com/get-article-detail-134439.html][https_www.liangzl.com_get-article-detail-134439.html]

spring-cloud-starter-bus-kafka-1.3.1.RELEASE:  [https://www.mvnjar.com/org.springframework.cloud/spring-cloud-starter-bus-kafka/1.3.1.RELEASE/detail.html][https_www.mvnjar.com_org.springframework.cloud_spring-cloud-starter-bus-kafka_1.3.1.RELEASE_detail.html]

[SpringCloud实战8-Bus消息总线][SpringCloud_8-Bus]: [https://www.cnblogs.com/huangjuncong/p/9077099.html][SpringCloud_8-Bus]

spring cloud : 消息中间件kafka:  [https://www.cppentry.com/bencandy.php?fid=120&id=193966][https_www.cppentry.com_bencandy.php_fid_120_id_193966]

spring cloud : 消息中间件kafka: [https://www.cppentry.com/bencandy.php?fid=120&id=193966][https_www.cppentry.com_bencandy.php_fid_120_id_193966]

[SpringCloud Bus消息总线][SpringCloud Bus]:  [https://www.cnblogs.com/toov5/p/10293755.html][SpringCloud Bus]

Spring Cloud Bus整合Kafka: [https://blog.csdn.net/u012702547/article/details/78630436?utm\_source=tuicool&utm\_medium=referral][https_blog.csdn.net_u012702547_article_details_78630436_utm_source_tuicool_utm_medium_referral]

Spring cloud 加入消息总线后,不能访问controller: [https://bbs.csdn.net/topics/392260453][https_bbs.csdn.net_topics_392260453]

Spring Cloud Bus + RabbitMq 自动刷新:  [https://my.oschina.net/u/3747963/blog/1595746][https_my.oschina.net_u_3747963_blog_1595746]

[spring cloud bus原理总结][spring cloud bus]: [https://www.cnblogs.com/songxh-scse/p/7833963.html][spring cloud bus]

springcloud微服务追踪使用kafka对zipkin进行传输:  [https://bbs.csdn.net/topics/392482048][https_bbs.csdn.net_topics_392482048]

[Spring Cloud Starter Bus Kafka][] » [2.0.0.RELEASE][]: [https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-bus-kafka/2.0.0.RELEASE][2.0.0.RELEASE]

Spring Cloud 基于Bus 的AB-TEST组件:  [https://cloud.tencent.com/developer/news/381266][https_cloud.tencent.com_developer_news_381266]

SpringCloud 微服务 (十) 消息队列MQ 基础:  [https://my.oschina.net/u/3829444/blog/1836946][https_my.oschina.net_u_3829444_blog_1836946]

Spring Cloud Bus + kafka实现配置中心配置动态更新: [https://www.jianshu.com/p/cc8fa1d58e3f][https_www.jianshu.com_p_cc8fa1d58e3f]

[SpringCloud学习之SpringCloudStream&集成kafka][SpringCloud_SpringCloudStream_kafka]: [https://www.cnblogs.com/niechen/p/8687206.html][SpringCloud_SpringCloudStream_kafka]

[SpringCloud学习之SpringCloudStream&集成kafka][SpringCloud_SpringCloudStream_kafka]:  [https://www.cnblogs.com/niechen/p/8687206.html][SpringCloud_SpringCloudStream_kafka]

Spring Cloud 基于Bus 的AB-TEST组件: [https://www.jianshu.com/p/d2d4075888dd][https_www.jianshu.com_p_d2d4075888dd]

Spring Cloud入门教程(十)：消息总线(Bus): [https://www.jianshu.com/p/bab2da26f282][https_www.jianshu.com_p_bab2da26f282]

一站通关Spring、SpringBoot与SpringCloud视频: [http://blog.sina.com.cn/s/blog\_139f782260102yfjx.html][http_blog.sina.com.cn_s_blog_139f782260102yfjx.html]

spring cloud bus整合kafka问题：  [https://bbs.csdn.net/topics/392179985?page=1][https_bbs.csdn.net_topics_392179985_page_1]

Spring Cloud系列教程 | 第十篇：Spring Cloud Config Server和Spring Cloud Bus以及Kafka和数据库动态刷新配置： [https://blog.csdn.net/qq\_43253123/article/details/82884027][https_blog.csdn.net_qq_43253123_article_details_82884027]

[SpringCloud 分布式配置][SpringCloud]： [https://www.cnblogs.com/zhangjianbin/p/6347247.html][SpringCloud]

Spring boot2.0 springcloud Finchley配置kafka消息总线bus：  [https://www.cppentry.com/bencandy.php?fid=120&id=204263][https_www.cppentry.com_bencandy.php_fid_120_id_204263]

3.《kafka》SpringCloud学习之SpringCloudStream&集成kafka： [https://www.jianshu.com/p/412f2887992a][https_www.jianshu.com_p_412f2887992a]

[spring cloud bus 配置服务端无法连接kafka][spring cloud bus _kafka]： [https://segmentfault.com/q/1010000018531564?utm\_source=tag-newest][https_segmentfault.com_q_1010000018531564_utm_source_tag-newest]

原 史上最简单的SpringCloud教程 | 第八篇: 消息总线(Spring Cloud Bus)(Finchley版本)： [https://blog.csdn.net/forezp/article/details/81041062][https_blog.csdn.net_forezp_article_details_81041062]

[SpringCloud Bus][SpringCloud Bus 1]： [https://www.cnblogs.com/ming-blogs/p/10940900.html][SpringCloud Bus 1]

Spring Cloud构建微服务架构（七）消息总线（续：Kafka）： [https://blog.csdn.net/zl1zl2zl3/article/details/60318644][https_blog.csdn.net_zl1zl2zl3_article_details_60318644]

Spring Cloud Config + Spring Cloud Bus + kafka实现配置中心配置动态更新：  [https://www.cppentry.com/bencandy.php?fid=120&id=213780][https_www.cppentry.com_bencandy.php_fid_120_id_213780]

Spring Cloud Bus 消息总线 kafka 集成配置：  [https://www.cppentry.com/bencandy.php?fid=120&id=201500][https_www.cppentry.com_bencandy.php_fid_120_id_201500]

[spring cloud 使用spring cloud bus自动刷新配置][spring cloud _spring cloud bus]： [https://www.cnblogs.com/pypua/p/10129734.html][spring cloud _spring cloud bus]

Spring Cloud Bus中的事件的订阅与发布（一）： [https://www.jianshu.com/p/d62612947e9e][https_www.jianshu.com_p_d62612947e9e]

springcloud配置中心刷新失败http://localhost:8881/actuator/bus-refresh（已解决）： [https://blog.csdn.net/firestarwolf/article/details/88718983][https_blog.csdn.net_firestarwolf_article_details_88718983]

[跟我学SpringCloud | 第八篇：Spring Cloud Bus 消息总线][SpringCloud _ _Spring Cloud Bus]： [http://www.ppkanshu.com/index.php/post/2423.html][SpringCloud _ _Spring Cloud Bus]

Spring Cloud Bus： [https://blog.csdn.net/xichenguan/article/details/77535694][https_blog.csdn.net_xichenguan_article_details_77535694]

Config Server——使用Spring Cloud Bus自动刷新配置： [https://blog.csdn.net/weixin\_34252686/article/details/86879431][https_blog.csdn.net_weixin_34252686_article_details_86879431]

[SpringCloud Bus 消息总线][SpringCloud Bus 2]： [https://segmentfault.com/a/1190000017391824?utm\_source=tag-newest][https_segmentfault.com_a_1190000017391824_utm_source_tag-newest]

SpringCloud Bus 消息总线： [https://segmentfault.com/a/1190000017391824][SpringCloud Bus 2]

SpringCloud教程 | 第13篇：高可用的分布式配置中心 Spring Cloud Bus 消息总线集成（RabbitMQ）：  [https://blog.csdn.net/yangliuhbhd/article/details/80526525][https_blog.csdn.net_yangliuhbhd_article_details_80526525]

spring cloud bus： [https://blog.csdn.net/weixin\_34387284/article/details/86815694][https_blog.csdn.net_weixin_34387284_article_details_86815694]

Spring Cloud构建微服务架构（七）消息总线（续：Kafka）： [https://www.jianshu.com/p/730d86030a41?nomobile=yes][https_www.jianshu.com_p_730d86030a41_nomobile_yes]

3：SpringCloud Config配置中心的bus动态刷新： [http://www.luyixian.cn/news\_show\_36597.aspx][http_www.luyixian.cn_news_show_36597.aspx]

SpringCloud微服务实战之消息总线BUS-RabbitMQ： [https://blog.csdn.net/u012343297/article/details/78872564][https_blog.csdn.net_u012343297_article_details_78872564]

Spring Cloud (3) | spring cloud bus 消息总线kafka应用：  [https://www.cppentry.com/bencandy.php?fid=120&id=196368][https_www.cppentry.com_bencandy.php_fid_120_id_196368]

SpringCloud Bus 整合 RabbitMQ： [https://blog.csdn.net/qq\_36657997/article/details/83070498][https_blog.csdn.net_qq_36657997_article_details_83070498]

第八章: 通过消息总线 Spring Cloud Bus 实现配置文件刷新 (使用 Kafka)： [https://www.h3399.cn/201903/672369.html][https_www.h3399.cn_201903_672369.html]

微服务和大数据性能指标参考和相关组件：[http://www.sohu.com/a/327523699\_120232014][http_www.sohu.com_a_327523699_120232014]

idea创建springcloud项目图文教程(bus 消息总线)（十二）： [https://blog.csdn.net/hcmony/article/details/82777986][https_blog.csdn.net_hcmony_article_details_82777986]

23SpringCloud - Spring Cloud Config 中使用 Refresh： [https://blog.csdn.net/qq\_20042935/article/details/90475315][https_blog.csdn.net_qq_20042935_article_details_90475315]

java B2B2C Springcloud多租户电子商城系统-spring cloud bus原理总结： [https://yq.aliyun.com/articles/684959][https_yq.aliyun.com_articles_684959]

SpringCloud消息总线： [https://blog.csdn.net/orangeccx/article/details/78604914][https_blog.csdn.net_orangeccx_article_details_78604914]

SpringCloud学习之一前置知识理解： [https://blog.csdn.net/kaishizige/article/details/80232099][https_blog.csdn.net_kaishizige_article_details_80232099]

Spring Cloud Config + Spring Cloud Bus 实现配置文件动态刷新（版本 Finchley.RC1）： [https://blog.csdn.net/zth0825/article/details/81080642][https_blog.csdn.net_zth0825_article_details_81080642]

Spring Cloud Bus 消息总线介绍： [https://yq.aliyun.com/articles/697913][https_yq.aliyun.com_articles_697913]

springcloud+sleuth+zipkin+kafka+es： [https://blog.csdn.net/niemingming/article/details/79002846][https_blog.csdn.net_niemingming_article_details_79002846]

SpringCloud学习笔记： [https://blog.csdn.net/luohongtuCSDN/article/details/80968174][https_blog.csdn.net_luohongtuCSDN_article_details_80968174]

[Spring Cloud 微服务架构学习笔记与示例][Spring Cloud]： [https://www.cnblogs.com/edisonchou/p/java\_spring\_cloud\_foundation\_sample\_list.html][Spring Cloud]

SpringCloud入门最佳实践（一）微服务概述： [https://blog.csdn.net/qq\_33746789/article/details/82496932][https_blog.csdn.net_qq_33746789_article_details_82496932]

SpringCloud Stream-----2、消息生产与消费； [https://blog.csdn.net/hekewangzi/article/details/78466176][https_blog.csdn.net_hekewangzi_article_details_78466176]

Spring Cloud—十一、使用Spring Cloud Bus(消息总线)实现自动更新： [https://www.jianshu.com/p/97aefedec1b7][https_www.jianshu.com_p_97aefedec1b7]

[Spring Cloud学习系列第七篇【消息总线】][Spring Cloud 1]： [https://www.cnblogs.com/yipaihushuo/p/9428146.html][Spring Cloud 1]

Spring Cloud（十一）高可用的分布式配置中心 Spring Cloud Bus 消息总线集成（RabbitMQ）： [https://blog.csdn.net/yanpenglei/article/details/78891620][https_blog.csdn.net_yanpenglei_article_details_78891620]

通过Spring Cloud Bus配置Webhooks不能自动刷新的问题"message":"No message available","path":"/monitor"： [https://blog.csdn.net/jun\_1990/article/details/93622946][https_blog.csdn.net_jun_1990_article_details_93622946]

springcloud(九)：配置中心和消息总线（配置中心终结版）： [https://blog.csdn.net/liu\_dong\_kang/article/details/87881331][https_blog.csdn.net_liu_dong_kang_article_details_87881331]

事件监听机制（四）Spring Cloud Bus自定义实现RemoteApplicationEvent： [https://blog.csdn.net/shang\_xs/article/details/88051207][https_blog.csdn.net_shang_xs_article_details_88051207]‘

版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/wqh8522/article/details/79193873  
Kafka是分布式发布-订阅消息系统，最初由LinkedIn公司开发，之后成为之后成为Apache基金会的一部分，由Scala和Java编写。Kafka是一种快速、可扩展的、设计内在就是分布式的，分区的和可复制的提交日志服务。

在开始本文前，需要搭建kafka的环境，如果是在CentOS环境下，可以看看我前面的文章：CentOS7下Kafka的安装介绍 。其他平台下可以自行百度或Google。

在之前的环境中，需要修改server.properties文件，开启9092端口的监听：

listeners=PLAINTEXT://your.host.name:9092  
1  
SpringBoot简单整合Kafka  
因为SpringCloud是基于SpringBoot的，所以在使用SpringCloudBus整合之前先用SpringBoot整合并记录下来。

创建项目  
这里创建一个名为kafka-hello的SpringBoot项目，并添加以下依赖：

<dependencies>  
  <dependency>  
    <groupId>org.springframework.boot</groupId>  
    <artifactId>spring-boot-starter-web</artifactId>  
  </dependency>

<dependency>  
    <groupId>org.projectlombok</groupId>  
    <artifactId>lombok</artifactId>  
    <optional>true</optional>  
  </dependency>

<dependency>  
    <groupId>org.springframework.boot</groupId>  
    <artifactId>spring-boot-starter-test</artifactId>  
    <scope>test</scope>  
  </dependency>

<dependency>  
    <groupId>org.springframework.kafka</groupId>  
    <artifactId>spring-kafka</artifactId>  
    <version>1.1.1.RELEASE</version>  
  </dependency>

<dependency>  
    <groupId>com.google.code.gson</groupId>  
    <artifactId>gson</artifactId>  
    <version>2.8.2</version>  
  </dependency>  
</dependencies>  
  
消息实体类  
@Data  
public class Message \{  
    private Long id;//id  
    private String msg; //消息  
    private Date sendTime; //发送时间  
\}  
  
消息产生者  
在该类中创建一个消息发送的方法，使用KafkaTemplate.send()发送消息，wqh是Kafka里的Topic。

@Component  
@Slf4j  
public class KafkaSender \{

@Autowired  
    private KafkaTemplate<String,String> kafkaTemplate;

private Gson gson = new GsonBuilder().create();

public void send(Long i)\{  
        Message message = new Message();  
        message.setId(i);  
        message.setMsg(UUID.randomUUID().toString());  
        message.setSendTime(new Date());  
        log.info("========发送消息  "+i+" >>>>\{\}<<<<<==========",gson.toJson(message));  
        kafkaTemplate.send("wqh",gson.toJson(message));  
    \}  
\}  
  
消息接收类，  
在这个类中，创建consumer方法，并使用@KafkaListener注解监听指定的topic，如这里是监听wanqh和wqh两个topic。

@Component  
@Slf4j  
public class KafkaConsumer \{

@KafkaListener(topics = \{"wanqh","wqh"\})  
    public void consumer(ConsumerRecord<?,?> consumerRecord)\{  
        //判断是否为null  
        Optional<?> kafkaMessage = Optional.ofNullable(consumerRecord.value());  
        log.info(">>>>>>>>>> record =" + kafkaMessage);  
        if(kafkaMessage.isPresent())\{  
            //得到Optional实例中的值  
            Object message = kafkaMessage.get();  
            log.info(">>>>>>>>接收消息message =" + message);  
        \}  
    \}  
\}  
  
修改启动类  
@SpringBootApplication  
public class KafkaApplication \{

@Autowired  
    private KafkaSender kafkaSender;

@PostConstruct  
    public void init()\{  
      for (int i = 0; i < 10; i++) \{  
        //调用消息发送类中的消息发送方法  
        kafkaSender.send((long) i);  
      \}  
    \}  
    public static void main(String\[\] args) \{  
       SpringApplication.run(KafkaApplication.class, args);  
    \}  
\}  
  
配置文件  
spring.application.name=kafka-hello  
server.port=8080  
\#============== kafka ===================  
\# 指定kafka 代理地址，可以多个  
spring.kafka.bootstrap-servers=192.168.18.136:9092

\#=============== provider  =======================  
spring.kafka.producer.retries=0  
\# 每次批量发送消息的数量  
spring.kafka.producer.batch-size=16384  
spring.kafka.producer.buffer-memory=33554432

\# 指定消息key和消息体的编解码方式  
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer  
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

\#=============== consumer  =======================  
\# 指定默认消费者group id  
spring.kafka.consumer.group-id=test-consumer-group

spring.kafka.consumer.auto-offset-reset=earliest  
spring.kafka.consumer.enable-auto-commit=true  
spring.kafka.consumer.auto-commit-interval=100

\# 指定消息key和消息体的编解码方式  
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer  
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer  
  
测试  
直接启动该项目:

SpringCloudBus整合Kafka  
前面介绍使用RabbitMQ整合SpringCloudBus实现了消息总线，并且测试了动态刷新配置文件。RabbitMQ是通过引入spring-cloud-starter-bus-amqp模块来实现消息总线。若使用Kafka实现消息总线，我们可以直接将之前添加的spring-cloud-starter-bus-amqp替换成spring-cloud-starter-bus-kafka 。

这里我将前面的config-client复制一份，改名config-client-kafka。传送门：SpingCloudBus整合RabbitMQ

所添加的依赖：  
<dependencies>  
        <dependency>  
            <groupId>org.springframework.boot</groupId>  
            <artifactId>spring-boot-starter-web</artifactId>  
        </dependency>  
        <dependency>  
            <groupId>org.springframework.cloud</groupId>  
            <artifactId>spring-cloud-starter-config</artifactId>  
        </dependency>  
        <dependency>  
            <groupId>org.springframework.retry</groupId>  
            <artifactId>spring-retry</artifactId>  
        </dependency>  
        <dependency>  
            <groupId>org.springframework.boot</groupId>  
            <artifactId>spring-boot-starter-aop</artifactId>  
        </dependency>  
        <dependency>  
            <groupId>org.springframework.boot</groupId>  
            <artifactId>spring-boot-starter-actuator</artifactId>  
        </dependency>  
        <dependency>  
            <groupId>org.springframework.cloud</groupId>  
            <artifactId>spring-cloud-starter-eureka</artifactId>  
        </dependency>  
        <dependency>  
            <groupId>org.springframework.cloud</groupId>  
            <artifactId>spring-cloud-starter-bus-kafka</artifactId>  
        </dependency>  
    </dependencies>  
  
添加kafka的配置信息  
\#Kafka的服务端列表，默认localhost  
spring.cloud.stream.kafka.binder.brokers=192.168.18.136:9092  
\#Kafka服务端的默认端口，当brokers属性中没有配置端口信息时，就会使用这个默认端口，默认9092  
spring.cloud.stream.kafka.binder.defaultBrokerPort=9092  
\#Kafka服务端连接的ZooKeeper节点列表，默认localhost  
spring.cloud.stream.kafka.binder.zkNodes=192.168.18.136:2181  
\#ZooKeeper节点的默认端口，当zkNodes属性中没有配置端口信息时，就会使用这个默认端口，默认2181  
spring.cloud.stream.kafka.binder.defaultZkPort=2181  
  
测试方法与前一篇一样，不介绍了。

参考：

《SpringCloud微服务实战》  
SpringBoot Kafka 整合使用  
Spring Cloud构建微服务架构（七）消息总线（续：Kafka）  
项目地址：

https://gitee.com/wqh3520/  
原文\[地址：

SpringCloudBus使用Kafka实现消息总线  
\---------------------   
作者：wqh3520   
来源：CSDN   
原文：https://blog.csdn.net/wqh8522/article/details/79193873   
版权声明：本文为博主原创文章，转载请附上博文链接！

[https_blog.csdn.net_wqh8522_article_details_79193873]: https://blog.csdn.net/wqh8522/article/details/79193873
[http_blog.didispace.com_springcloud7-2]: http://blog.didispace.com/springcloud7-2/
[https_bbs.csdn.net_topics_392179985]: https://bbs.csdn.net/topics/392179985
[https_my.oschina.net_u_2263272_blog_1634010_nocache_1531813104906]: https://my.oschina.net/u/2263272/blog/1634010?nocache=1531813104906
[https_cloud.tencent.com_developer_news_251479]: https://cloud.tencent.com/developer/news/251479
[Spring Cloud Bus_Kafka]: https://segmentfault.com/a/1190000011752466
[https_www.cppentry.com_bencandy.php_fid_120_id_183602]: https://www.cppentry.com/bencandy.php?fid=120&id=183602
[SpringCloud_8-Bus]: https://www.cnblogs.com/huangjuncong/p/9077099.html
[SpringCloudBus_Kafka]: https://segmentfault.com/a/1190000013031488
[SpringCloud]: https://www.cnblogs.com/zhangjianbin/p/6347247.html
[https_blog.csdn.net_m0_37809146_article_details_86677462]: https://blog.csdn.net/m0_37809146/article/details/86677462
[https_blog.csdn.net_superdangbo_article_details_78776532]: https://blog.csdn.net/superdangbo/article/details/78776532
[https_blog.csdn.net_qqxx6661_article_details_88701051]: https://blog.csdn.net/qqxx6661/article/details/88701051
[https_blog.csdn.net_skywoodsky_article_details_80772848]: https://blog.csdn.net/skywoodsky/article/details/80772848
[https_blog.csdn.net_olinbsoft_article_details_86586467]: https://blog.csdn.net/olinbsoft/article/details/86586467
[https_blog.csdn.net_xiao_jun_0820_article_details_78115746]: https://blog.csdn.net/xiao_jun_0820/article/details/78115746
[https_blog.csdn.net_lixiaxin200319_article_details_82811047]: https://blog.csdn.net/lixiaxin200319/article/details/82811047
[http_www.itmuch.com_spring-cloud_spring-cloud-bus-auto-refresh-configuration]: http://www.itmuch.com/spring-cloud/spring-cloud-bus-auto-refresh-configuration/
[https_yq.aliyun.com_articles_613228]: https://yq.aliyun.com/articles/613228
[https_www.jianshu.com_p_730d86030a41]: https://www.jianshu.com/p/730d86030a41
[spring cloud bus_kafka]: https://geekori.com/details.php?que_id=8168
[https_ask.csdn.net_questions_761217]: https://ask.csdn.net/questions/761217
[https_springcloud.cc_spring-cloud-bus.html]: https://springcloud.cc/spring-cloud-bus.html
[http_blog.didispace.com_springcloud7]: http://blog.didispace.com/springcloud7/
[https_my.oschina.net_roccn_blog_832059]: https://my.oschina.net/roccn/blog/832059
[https_www.xujun.org_article308898.html]: https://www.xujun.org/article308898.html
[https_www.ucloud.cn_yun_8346.html]: https://www.ucloud.cn/yun/8346.html
[Spring Cloud Alibaba_-05-Sentinel]: http://ldnmen.com/spring-cloud-alibaba/05-sentinel/index.htm
[http_ldnmen.com]: http://ldnmen.com/
[https_www.douban.com_group_topic_146012302]: https://www.douban.com/group/topic/146012302/
[https_www.iteye.com_blogs_subjects_Spring-Cloud_4370]: https://www.iteye.com/blogs/subjects/Spring-Cloud#4370
[http_www.hellojava.com_a_79952.html]: http://www.hellojava.com/a/79952.html
[https_www.bcoder.top_2018_12_08_SpringCloud_E7_AC_94_E8_AE_B0]: https://www.bcoder.top/2018/12/08/SpringCloud%E7%AC%94%E8%AE%B0/
[http_server.51cto.com_Micro-550525.htm]: http://server.51cto.com/Micro-550525.htm
[http_www.spring4all.com_article_773]: http://www.spring4all.com/article/773
[mhuang]: https://gitee.com/mhuang
[mhuang-cloud-study]: https://gitee.com/mhuang/mhuang-cloud-study
[http_www.imooc.com_article_275387]: http://www.imooc.com/article/275387
[https_www.liangzl.com_get-article-detail-134439.html]: https://www.liangzl.com/get-article-detail-134439.html
[https_www.mvnjar.com_org.springframework.cloud_spring-cloud-starter-bus-kafka_1.3.1.RELEASE_detail.html]: https://www.mvnjar.com/org.springframework.cloud/spring-cloud-starter-bus-kafka/1.3.1.RELEASE/detail.html
[https_www.cppentry.com_bencandy.php_fid_120_id_193966]: https://www.cppentry.com/bencandy.php?fid=120&id=193966
[SpringCloud Bus]: https://www.cnblogs.com/toov5/p/10293755.html
[https_blog.csdn.net_u012702547_article_details_78630436_utm_source_tuicool_utm_medium_referral]: https://blog.csdn.net/u012702547/article/details/78630436?utm_source=tuicool&utm_medium=referral
[https_bbs.csdn.net_topics_392260453]: https://bbs.csdn.net/topics/392260453
[https_my.oschina.net_u_3747963_blog_1595746]: https://my.oschina.net/u/3747963/blog/1595746
[spring cloud bus]: https://www.cnblogs.com/songxh-scse/p/7833963.html
[https_bbs.csdn.net_topics_392482048]: https://bbs.csdn.net/topics/392482048
[Spring Cloud Starter Bus Kafka]: https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-bus-kafka
[2.0.0.RELEASE]: https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-bus-kafka/2.0.0.RELEASE
[https_cloud.tencent.com_developer_news_381266]: https://cloud.tencent.com/developer/news/381266
[https_my.oschina.net_u_3829444_blog_1836946]: https://my.oschina.net/u/3829444/blog/1836946
[https_www.jianshu.com_p_cc8fa1d58e3f]: https://www.jianshu.com/p/cc8fa1d58e3f
[SpringCloud_SpringCloudStream_kafka]: https://www.cnblogs.com/niechen/p/8687206.html
[https_www.jianshu.com_p_d2d4075888dd]: https://www.jianshu.com/p/d2d4075888dd
[https_www.jianshu.com_p_bab2da26f282]: https://www.jianshu.com/p/bab2da26f282
[http_blog.sina.com.cn_s_blog_139f782260102yfjx.html]: http://blog.sina.com.cn/s/blog_139f782260102yfjx.html
[https_bbs.csdn.net_topics_392179985_page_1]: https://bbs.csdn.net/topics/392179985?page=1
[https_blog.csdn.net_qq_43253123_article_details_82884027]: https://blog.csdn.net/qq_43253123/article/details/82884027
[https_www.cppentry.com_bencandy.php_fid_120_id_204263]: https://www.cppentry.com/bencandy.php?fid=120&id=204263
[https_www.jianshu.com_p_412f2887992a]: https://www.jianshu.com/p/412f2887992a
[spring cloud bus _kafka]: https://segmentfault.com/q/1010000018531564
[https_segmentfault.com_q_1010000018531564_utm_source_tag-newest]: https://segmentfault.com/q/1010000018531564?utm_source=tag-newest
[https_blog.csdn.net_forezp_article_details_81041062]: https://blog.csdn.net/forezp/article/details/81041062
[SpringCloud Bus 1]: https://www.cnblogs.com/ming-blogs/p/10940900.html
[https_blog.csdn.net_zl1zl2zl3_article_details_60318644]: https://blog.csdn.net/zl1zl2zl3/article/details/60318644
[https_www.cppentry.com_bencandy.php_fid_120_id_213780]: https://www.cppentry.com/bencandy.php?fid=120&id=213780
[https_www.cppentry.com_bencandy.php_fid_120_id_201500]: https://www.cppentry.com/bencandy.php?fid=120&id=201500
[spring cloud _spring cloud bus]: https://www.cnblogs.com/pypua/p/10129734.html
[https_www.jianshu.com_p_d62612947e9e]: https://www.jianshu.com/p/d62612947e9e
[https_blog.csdn.net_firestarwolf_article_details_88718983]: https://blog.csdn.net/firestarwolf/article/details/88718983
[SpringCloud _ _Spring Cloud Bus]: http://www.ppkanshu.com/index.php/post/2423.html
[https_blog.csdn.net_xichenguan_article_details_77535694]: https://blog.csdn.net/xichenguan/article/details/77535694
[https_blog.csdn.net_weixin_34252686_article_details_86879431]: https://blog.csdn.net/weixin_34252686/article/details/86879431
[SpringCloud Bus 2]: https://segmentfault.com/a/1190000017391824
[https_segmentfault.com_a_1190000017391824_utm_source_tag-newest]: https://segmentfault.com/a/1190000017391824?utm_source=tag-newest
[https_blog.csdn.net_yangliuhbhd_article_details_80526525]: https://blog.csdn.net/yangliuhbhd/article/details/80526525
[https_blog.csdn.net_weixin_34387284_article_details_86815694]: https://blog.csdn.net/weixin_34387284/article/details/86815694
[https_www.jianshu.com_p_730d86030a41_nomobile_yes]: https://www.jianshu.com/p/730d86030a41?nomobile=yes
[http_www.luyixian.cn_news_show_36597.aspx]: http://www.luyixian.cn/news_show_36597.aspx
[https_blog.csdn.net_u012343297_article_details_78872564]: https://blog.csdn.net/u012343297/article/details/78872564
[https_www.cppentry.com_bencandy.php_fid_120_id_196368]: https://www.cppentry.com/bencandy.php?fid=120&id=196368
[https_blog.csdn.net_qq_36657997_article_details_83070498]: https://blog.csdn.net/qq_36657997/article/details/83070498
[https_www.h3399.cn_201903_672369.html]: https://www.h3399.cn/201903/672369.html
[http_www.sohu.com_a_327523699_120232014]: http://www.sohu.com/a/327523699_120232014
[https_blog.csdn.net_hcmony_article_details_82777986]: https://blog.csdn.net/hcmony/article/details/82777986
[https_blog.csdn.net_qq_20042935_article_details_90475315]: https://blog.csdn.net/qq_20042935/article/details/90475315
[https_yq.aliyun.com_articles_684959]: https://yq.aliyun.com/articles/684959
[https_blog.csdn.net_orangeccx_article_details_78604914]: https://blog.csdn.net/orangeccx/article/details/78604914
[https_blog.csdn.net_kaishizige_article_details_80232099]: https://blog.csdn.net/kaishizige/article/details/80232099
[https_blog.csdn.net_zth0825_article_details_81080642]: https://blog.csdn.net/zth0825/article/details/81080642
[https_yq.aliyun.com_articles_697913]: https://yq.aliyun.com/articles/697913
[https_blog.csdn.net_niemingming_article_details_79002846]: https://blog.csdn.net/niemingming/article/details/79002846
[https_blog.csdn.net_luohongtuCSDN_article_details_80968174]: https://blog.csdn.net/luohongtuCSDN/article/details/80968174
[Spring Cloud]: https://www.cnblogs.com/edisonchou/p/java_spring_cloud_foundation_sample_list.html
[https_blog.csdn.net_qq_33746789_article_details_82496932]: https://blog.csdn.net/qq_33746789/article/details/82496932
[https_blog.csdn.net_hekewangzi_article_details_78466176]: https://blog.csdn.net/hekewangzi/article/details/78466176
[https_www.jianshu.com_p_97aefedec1b7]: https://www.jianshu.com/p/97aefedec1b7
[Spring Cloud 1]: https://www.cnblogs.com/yipaihushuo/p/9428146.html
[https_blog.csdn.net_yanpenglei_article_details_78891620]: https://blog.csdn.net/yanpenglei/article/details/78891620
[https_blog.csdn.net_jun_1990_article_details_93622946]: https://blog.csdn.net/jun_1990/article/details/93622946
[https_blog.csdn.net_liu_dong_kang_article_details_87881331]: https://blog.csdn.net/liu_dong_kang/article/details/87881331
[https_blog.csdn.net_shang_xs_article_details_88051207]: https://blog.csdn.net/shang_xs/article/details/88051207