《七牛云》专题

有一个带有Spring-Boot1.5的微服务，它使用假动作与其他服务通信，还有spring-cloud-starter-zipkin，它通过假动作包装所有调用，并将跟踪发送到zipkin服务器。问题是我不想包装所有的电话并跟踪它们，只有几个最重要的做到这一点。我如何从跟踪中排除一些带有假动作的调用（方法），或者驱逐一些整个假动作的客户端（接口）？

Spring Cloud Sleuth跟踪头是否像这里描述的RabbitMq和Kafka那样被注入到Spring Cloud Stream Kinesis消息中？我们有一个REST控制器，它在处理POST请求之后，但在向客户机发送响应之前，向Kinesis发送一个Avro消息，该消息使用Spring Cloud Stream Kinesis总结事务。我想确保在REST控制器中启动的跟踪id被传播到

我正在尝试将StreamsUncaughtExceptionHandler添加到我的Kafka流处理器。该处理器使用Kafka函数编写。我查看了Artem Bilan提供的将StreamsUncaughtExceptionHandler包括到我的服务中的建议，但我的异常从未被它捕获/处理。 配置Bean： 自定义异常处理程序： 流处理功能： 我希望UnCaughtExceptionHandler处

我已经使用Spring云流启动了一个小型微服务。 我只有两个流绑定，如下所示： 我用Serenity开发了组件测试，我将通道注入到我想要发送测试消息的地方： 哪里： 只是定义为字符串常量： 组件测试模块导入依赖项： 我发送的信息如下： 快乐流工作正常。但是，我想在侦听器无法处理消息时测试错误流。 这是一个监听器的例子： 从try/catch引发异常时，错误由服务激活器处理： 在没有Spring-C

一段时间以来，我一直试图让Spring Cloud Stream与Kafka Streams一起使用，我的项目使用嵌入式kafka进行Kafka DSL测试，我使用这个存储库作为我的测试实现的基础（它本身就是这个问题的测试用例）。 我在这里制作了一个存储库来演示这一点。 基本上，当使用“Processor.class”的“DemoApplicationTest.ExampleAppWorking.

Spring Cloud Kafka Streams与Spring Cloud Stream、Spring Cloud Function、Spring AMQP和Spring for Apache Kafka有什么区别？

我在这个网站上用docker compose启动了Spring云数据流。 https://dataflow.spring.io/docs/installation/local/docker/ 我创建了3个应用程序，源，处理器 我跑了 当我运行docker compose-f时/docker编写。yml-f/docker创作普罗米修斯。yml，所有我的容器都按照docker compose中的指定启

我正在尝试在Spring云数据流中配置DLQ。下面是流定义以及我如何部署它 在自定义转换处理器代码中，我已经提到过 这意味着若消息包含错误，那个么RunTimeException和我想在DLQ中捕获这些消息。但当我运行代码时，似乎没有得到任何名为test tran的Kafka DL队列。 我是否需要设置更多属性来启用DLQ，还是需要更改代码中的某些内容以正确使用DLQ。 自定义转换代码 Trans

我有一个简单的SCDF流，如下所示： http--端口=12346 | mvmn转换|文件--名称=tmp。txt--目录=/tmp mvmn变换是一个简单的自定义变压器，如下所示： 这很好用。 但我读到，Spring云函数应该允许我实现这样的应用程序，而无需指定绑定和转换器注释，所以我将其更改为： 现在我有一个问题-Spring云函数显然忽略了SCDF源和目标主题名称，而创建了主题和。 SCDF

有没有办法允许（Spring Cloud Stream）应用程序在融合云中自动创建所需的主题？ 到目前为止，我不得不手动创建它们，当您考虑还必须设置变更日志主题时，这很容易出错。

我正在使用ConFluent托管的Kafka集群和Schema注册表服务。我可以管理连接汇合云kafka集群，将以下属性添加到生产者配置（Scala） 但是不能连接到汇合云模式注册表。汇合云模式注册表提供了访问的键和秘密，但我不知道如何设置键和秘密。是否有任何配置设置用于访问汇合云模式注册表。

我有一个使用Spring cloud stream和Kafka Streams活页夹的项目。对于流的输出，我使用的是Avro，Serde由Confluent提供（

我正在尝试用kafka绑定构建一个简单的云流应用程序。让我描述一下设置。1、我有一位制作人正在制作主题1 2。有一个流活页夹，经过一些处理后将主题1绑定到主题2。 我是这些技术的新手。无法弄清楚这里出了什么问题。有人能帮忙吗？

我开始开发一个spring cloud stream项目。我已通过@Streamlistener注释成功接收到来自Kafka的消息。在将消息发送到任何输出通道之前，我必须通过调用externalservice或DB调用来转换有效负载。我不想从同一个streamlistener方法调用外部服务或DB方法。我的问题是，我们能否在Spring云流中创建内部通道（如Spring集成DSL流）？

我现在一直在查看Spring Cloud模式注册表和汇合模式注册表。我可以看到一些区别，例如Spring Cloud模式注册表将模式保存在普通数据库中，默认情况下保存在h2中，而汇合模式注册表保存在kafka主题中。 spring云模式注册表的这种方法是否会对性能产生任何影响。据我所知，即使数据保留在主题上，以防汇合，查询它时仍然会有延迟。但会有重大影响吗？ 我还可以看到，spring云模式注册表