问题标签 [spring-cloud-bus]

问问题

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

56 问题
Newest
Active
Bountied
318
Unanswered
0 投票
1 回答
376 浏览

spring-cloud - Spring Cloud 2020.0.0 中的 Spring Cloud Bus/Stream 问题

我们有一个 Spring Boot 微服务，除了 HTTP 端点使用 Spring Cloud Bus 来获取刷新事件（来自 rabbit），还有一个 Spring Cloud Stream Sink 可以从另一个 rabbit 主题中获取自定义消息。

在更新到 Spring Boot 2.4.1 和 Spring Cloud 2020.0.0 之后，一切似乎都在工作，直到我们发现 Spring Cloud Bus 不再接收事件。对此进行调查，结果发现一些 Spring Cloud Bus 内部通道没有被创建。

这在另一个没有流功能的服务中没有发生，所以我们测试了禁用它，然后总线功能开始工作。所以这显然是旧式流模型和新的 Spring Cloud Bus 之间的某种干扰。

在更新我们的接收器以使用新的功能模型后，我仍然遇到问题，最终通过在我们的 application.yml 中包含以下几行来让两者都工作：

所以我有以下问题

  1. 我是否遗漏了什么，或者是否应该有更好的文档来说明流/总线如何相互影响以及迁移到 2020.0.0？
  2. 我当前的配置看起来正确吗？
  3. 必须在此处包含 busConsumer 似乎是不对的 - 它的自动配置是否应该不能与任何其他流配置“组合”？
  4. spring.cloud.stream.function.definition和有什么区别spring.cloud.function.definition？我在文档中都看到过，而且 Spring Cloud Bus 似乎也在设置spring.cloud.function.definition=busConsumer
0 投票
0 回答
199 浏览

spring-boot - 将 spring-cloud-config 与 spring-cloud-bus 一起使用

我会使用 spring-cloud-bus 来刷新配置应用程序。目前我的工作失败了。似乎配置与旧版本不完全相同。 在我的配置服务器 pom：

在服务器配置 application.yml

在应用程序中进行配置

pom：（ 父级的spring boot和spring cloud依赖版本相同）

在 application.yml 中：

目前，当我在 github 上更新配置时，webhook 调用 configuration-server 但我有 400 错误。在配置服务器日志中，我有：

我不明白什么是“路径”。你能给我一些帮助吗？谢谢。

0 投票
0 回答
122 浏览

spring-boot - Spring Cloud Config Server JDBC + kafka 自动更新

我正在尝试设置 spring cloud config-server + jdbc (postgres) + kafka bus

不幸的是，我找不到任何关于如何通过 Kafka 实现自动刷新的信息。

我已经阅读了https://cloud.spring.io/spring-cloud-static/spring-cloud-config/2.0.2.RELEASE/single/spring-cloud-config.html#_push_notifications_and_spring_cloud_bus 文章，但所有关于 auto- refresh 连接到 GitHub webhook 并将 POST 请求发送到 config-server /monitor 端点。

所以，目前，我试图找到问题的答案：

  1. 如何使用 JDBC 在 Kafka 中进行配置自动刷新
  2. 更新到 Kafka 中的哪个主题（我的 application.yml 中没有设置任何内容）
0 投票
0 回答
317 浏览

spring-boot - Spring cloud bus - java.lang.ClassCastException: java.lang.String 无法转换为 org.springframework.cloud.bus.event.RemoteApplicationEvent

我正在使用 Spring Cloud 配置在运行时更改属性值。将 spring boot 升级到 2.4.3 版本并将 spring cloud 升级到 2020.0.3 后，我面临以下问题：

我发现如果我将 spring.cloud.bus 降级到 2.2.4.RELEASE 版本，那么一切正常。

卡夫卡属性：

请注意，如果我将 ByteArraySerializer 更改为 StringSerializer 然后我得到：

0 投票
1 回答
201 浏览

spring - Spring Cloud Bus with rabbit - 应用程序无法启动

我正在尝试创建一个侦听 Git 事件并将事件流式传输到客户端的配置服务器。我遵循了几个示例以及文档，但我无法启动应用程序。我想我对 spring boot 和 cloud 版本有问题。

重要的是要提到我用 docker 运行 rabbitmq。

这是我的 build.gradle

这是我得到的例外：

有谁知道错误配置在哪里？

0 投票
1 回答
41 浏览

spring-cloud - spring-cloud 中的通用适配器模式，允许您发布/订阅不同的消息服务

spring-cloud 中是否有通用适配器模式允许您发布/订阅消息？基本上允许您将提供程序类型更改为 ampq、kafka、pubsub 或 jms。商业案例能够改变发布/订阅消息服务，避免云供应商锁定。一个简单的 pub/sub 统一通用框架。示例代码。

史蒂夫


12345678910