一、关于Spring-Cloud-Stream 　　Spring Cloud Stream本质上就是整合了Spring Boot和Spring Integration，实现了一套轻量级的消息驱动的微 ...

一、Spring cloud stream概述 Spring Cloud Stream是构建消息驱动的微服务应用程序框架。提供统一的接收发送管道以连接到消息代理。通过@EnableBinding注解开启SpringCloudStream的支持。通过@StreamListener注解，使其接收 ...

准备工作 安装kafka+zookeeper环境 利用命令创建好topic Pom文件,引入spring-kafka jar包这里需要注意2个地方： kafka-clients 包版本与服务器端kafka-clients版本保持一致（查看服务器 ...

1.解决的痛点 由于市面上有很多的消息中间件（activeMQ，rabbitMQ,RocketMQ,Kafka）,当某一天公司切换某一种新的消息中间件的时候，使得我们工作量会变大，增加学习量。 那么有没有一种新技术，能让我们不在关注具体的MQ细节，我们只需要用一种适配绑定的方式，自动的给我 ...

　　在spring应用中如果需要订阅kafka消息，通常情况下我们不会直接使用kafka-client, 而是使用更方便的一层封装spring-kafka。　　在spring-kafka在运行时会启动两类线程，一类是Consumer线程，另一类是Listener线程。前者用来直接调用 ...

springboot集成kafka 本项目是基于Windows环境开发的。 环境要求： 1.JDK环境。 2.zookeeper环境。 3.kafka安装。 以上3步百度都有安装教程。 4.kafka问题 a:kafka启动失败，提示jdk环境不存在。 解决 ...

一、准备 1、启动zookeeper 2、启动kafka 3、kafka创建主题。主题名称为：couponTopic ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor ...

一、windows安装ZooKeeper 1、 下载安装包 我下的是zookeeper-3.5.9 http://zookeeper.apache.org/releases.html#downl ...