《七牛云》专题

对于托管在 Confluent Cloud 中的 Kafka 集群，会创建一个审核日志集群。似乎可以将接收器连接器挂接到此群集，并从“汇合审核日志事件”主题中排出事件。 但是，当我运行连接器执行相同操作时，我遇到了以下错误。 在我的connect-distributed.properties文件中，我的设置如下: 需要授予哪些额外的权限，以便连接器可以在集群中创建所需的主题？connect-dis

在 spring-cloud-netflix 设置中（一切都使用 feign、ribbon、eureka、zuul），是否有任何简单/优雅/开箱即用的方式（即基于 serviceId 与 URL 的发现）让 CompositeAB 通过 Zuul 与 ServiceA 和 ServiceB 通信？在我看到的所有示例中，CompositeAB 直接发现并调用 ServiceA，而不是通过 Servi

我正在努力实现以下目标: 能够使用Azure用户分配的管理身份（UAMI）从Spring启动应用程序（部署在AKS中）向vault（部署在Azure上）进行身份验证 栈:openjdk 8，spring boot 2.5.4，spring-cloud-starter-vault-config 3 . 0 . 3，AKS 我在azure上安装了hashicorp保险库。下面的文档建议我可以在这种情况

我试图修改我们目前的Spring云配置服务器，它只有一个JDBC后端，以包括一个保险库后端，以使JDBC连接证书保密。 库： bootstrap.yml 应用程序. yml 没有从vault中检索spring.datasource用户名和密码。

我有一个 Spring 启动应用程序正在运行并使用 Spring 云网关。该应用程序在 kubernetes 上运行（在 EKS 和本地 docker 桌面上尝试过）。我在访问指向另一个命名空间（非默认）中的服务的路由时遇到问题。当我启动 http://localhost:8080/actuator/gateway/routes 时，我看到下面的路线是路线之一 在应用程序中。yml，我添加了以下网

我实现了Spring云任务示例中给出的示例批处理作业示例。其中使用的 Spring 引导版本是 2.0.1.RELEASE。由于我必须移植另一个作业，因此我必须启动云任务，因此我想找到兼容的最旧版本。使用 1.3.2.RELEASE 创建的批处理作业的 jar 作为 Spring 引导版本成功运行。但是当我在将其添加为应用程序后从 Spring 云数据流的 UI 运行它时，出现以下错误：

我正在使用带有Spring启动 2.5.8 的 Spring Cloud 2020.0.2 和 spring-kafka：2.6.6。这工作正常。但是当我将Spring云升级到 2020.0.4 时，Spring kafka 会抛出以下错误。 邮件处理异常，缺少标头kafka_acknowledgement。 有谁能帮我一下spring cloud 2020.0.2和spring-kafka:2.

我是Spring云流的新手。我正在使用兔子MQ粘合剂。问题是当我在主类中使用单个 bean 启动应用程序时，它就成功启动了。但是，如果我在主类中注册了 1 个以上的 bean，则应用程序无法从以下日志启动。 application.yml文件

我正在尝试使用Spring Cloud Stream处理发送到Azure Event Hub实例的消息。这些消息应该路由到Kafka集群上运行时根据消息内容确定的租户特定主题。出于开发目的，我通过Docker在本地运行Kafka。我对配置时未知的绑定进行了一些研究，发现动态目标解析可能正是我在这个场景中所需要的。 然而，让我的解决方案工作的唯一方法是使用。我宁愿使用动态目标标头，这样处理器就可以被

我们目前正在使用 SpringXD 将数据从各种数据源摄取到接收器。由于 Springxd 计划终止可用性，我们希望迁移到 Spring Cloud 数据流。 < li >我们为SpringXD编写了几个自定义模块。如何在SCDF使用相同的模块。在SCDF使用这些需要做什么改变。 < li >我们的集群配置了kerberos，SCDF支持kerberized kafka和hadoop吗？。 < l

我们正在将我们的工作和数据流从Spring XD迁移到Kubernetes上的Spring cloud数据流。 Spring cloud数据流有商业支持吗？任何链接都有帮助。

我在Spring云数据流流中遇到 HTTP 源应用程序的问题。 当我尝试将具有巨大体量的 HTTP 请求发布到 HTTP endpoint时，就会发生这种情况。 我尝试在部署中设置以下属性，但没有帮助: 春云启动器HTTP Kafka源码app使用的版本是3.1.1 有人知道如何解决这个问题吗？ 这可以以如下所示的独立方式进行最低限度的复制 从https://mvnrepository.com/a

是否可以为Apache Kafka的Spring Cloud DataFlow配置身份验证？在哪里可以看到示例？ 谢谢你。

假设我有一个包含3个应用程序的流——一个源、处理器和接收器。 我需要保留从源收到的消息的顺序。当我收到消息A，B，C，D，我必须将它们作为A，B，C，D.发送到接收器（我不能将它们作为B，A，C，D）发送。 如果每个应用程序只有一个实例，那么一切都将按顺序运行，并且顺序将被保留。 如果我每个应用程序有 10 个实例，则消息 A、B、C、D 可能会在不同的实例中同时处理。我不知道这些消息的顺序是什么

我正在尝试根据 http://cloud.spring.io/spring-cloud-dataflow/ 中解释的非常简单的示例运行“Hello，world”Spring Cloud 数据流流。我能够创建一个简单的源代码和接收器，并使用 Kafka 在本地 SCDF 服务器上运行它，因此到目前为止一切都是正确的，并且在 SCDF 指定的主题中生成和使用消息。 现在，我正在尝试根据http://d