使用Kafka代替spring云总线
让我用一个例子来解释我的问题，
- 有一种叫做“通知服务”的微服务
- 它有2个实例在端口8080和8081中运行
- 我们的Spring云配置服务器也在运行，并包含“通知服务”的所有属性文件
当属性文件更改时，为了使其立即影响所有正在运行的实例，我们可以使用sping-Cloud-bus，
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
并使用邮递员工具一次刷新“通知服务”的所有实例。
- 例如，localhost:8080/bus/refresh
我想知道的是，有没有办法用kafka代替春云巴士来实现这一点？
共有1个答案
也许你在找这个？
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-stream-kafka</artifactId>
<version>2.1.0.RELEASE</version>
</dependency>
它叫做Spring的云流
-
使用Spring for Apache Kafka或Spring AMQP，我可以实现消息发布/订阅。Spring云总线使用Kafka/rabbitmq来完成大致相同的事情，它们之间的区别是什么？
-
我想在我的项目中使用Spring Cloud Bus来动态更新配置。我们的环境中已经有Apache ActiveMQ。有没有可能使用ActiveMQ而不是RabbitMQ作为代理？它们都是一种AMQP服务器。 我在pom.xml中设置依赖项如下： 它看起来像一个标准的AMQP启动器，不限于RabbitMQ。但是，当配置服务器启动时，以下错误日志会提示：
-
我试图找到一些Spring Cloud数据流和Azure服务总线设置的示例。. 我找到了https://github.com/microsoft/spring-cloud-azure/tree/master/spring-cloud-azure-stream-binder/spring-cloud-azure-servicebus-topic-stream-binder，但它仍然在RC中，我没有看
-
我有三个应用程序，一个是spring云配置服务器点，另一个是spring云配置客户endpoint。我在彼此中配置了spring云总线，以使客户endpoint自动刷新发生更改，但在我运行的应用程序中，出现了如下异常 这是我的spring云服务器配置 这是我的spring云配置服务器pom 这是我的spring云配置客户端配置 这是我的spring云配置客户端pom 此异常不会影响操作的应用程序，
-
我正在尝试将StreamsUncaughtExceptionHandler添加到我的Kafka流处理器。该处理器使用Kafka函数编写。我查看了Artem Bilan提供的将StreamsUncaughtExceptionHandler包括到我的服务中的建议，但我的异常从未被它捕获/处理。 配置Bean： 自定义异常处理程序： 流处理功能： 我希望UnCaughtExceptionHandler处
-
我正在尝试用《Spring的云流》和《Kafka》。下面是示例代码。但它似乎没有任何作用。它总是创建一个名为“输出”的主题。但这些价值观尚未公布。 应用亚马尔 我的目标就是创造价值。 依赖性-2.2.6。释放