Spring Integration DSL Scatter-Gatherer:为什么applySequence(true)不是默认的？
Spring Integration DSL Scatter-Gatherer是Spring Integration框架中的一个组件，用于将输入消息分散到多个处理器进行并行处理，并将处理结果进行聚合。在使用Scatter-Gatherer时，可以通过调用applySequence(true)方法来启用消息序列化。
为什么applySequence(true)不是默认的呢？
applySequence(true)方法的作用是为每个分散的消息添加一个序列号。这样做的目的是为了在聚合阶段能够正确地将处理结果与原始输入消息进行匹配。当启用消息序列化时，Scatter-Gatherer会为每个分散的消息添加一个序列号，并在聚合阶段根据序列号将处理结果与原始输入消息进行匹配。
然而，将applySequence(true)设置为默认值可能会带来一些潜在的问题。首先，启用消息序列化会增加一定的开销，因为需要为每个分散的消息添加序列号。对于一些简单的场景，用户可能并不需要关心消息的顺序，因此默认情况下禁用消息序列化可以提高性能。
其次，启用消息序列化可能会引入一些潜在的问题，例如消息的乱序问题。在并行处理的情况下，处理器的执行顺序是不确定的，因此处理结果的返回顺序也是不确定的。如果在聚合阶段依赖于消息的顺序进行处理，可能会导致结果的不一致性。
因此，Spring Integration DSL Scatter-Gatherer默认情况下不启用消息序列化，以提高性能并避免潜在的问题。如果用户确实需要保持消息的顺序，并且能够处理可能出现的问题，可以手动调用applySequence(true)方法来启用消息序列化。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云云服务器（CVM）：https://cloud.tencent.com/product/cvm
- 腾讯云云原生容器服务（TKE）：https://cloud.tencent.com/product/tke
- 腾讯云数据库（TencentDB）：https://cloud.tencent.com/product/cdb
- 腾讯云人工智能（AI）：https://cloud.tencent.com/product/ai
- 腾讯云物联网（IoT）：https://cloud.tencent.com/product/iot
- 腾讯云移动开发（移动推送、移动分析等）：https://cloud.tencent.com/product/mobile
- 腾讯云对象存储（COS）：https://cloud.tencent.com/product/cos
- 腾讯云区块链（BCS）：https://cloud.tencent.com/product/bcs
- 腾讯云游戏多媒体引擎（GME）：https://cloud.tencent.com/product/gme
- 腾讯云音视频处理（VOD）：https://cloud.tencent.com/product/vod
- 腾讯云网络安全（SSL证书、DDoS防护等）：https://cloud.tencent.com/product/safety
相关·内容
我见过的Spring Integration DSL Scatter-Gatherer的所有示例都显式地在散射器上设置了.applySequence(true)。 例如： @Bean
public IntegrationFlow helloFlow() {
return IntegrationFlows
.from(Http.inboundChannelAdapter("hello").get())
.scatterGather(s -> s
.applySequence(t
浏览 60提问于2021-07-16得票数 0
回答已采纳
如果我想为了测试Spring Integration DSL功能而生成一些样本数据，到目前为止我想出的一种方法如下： @Bean
public IntegrationFlow myFlow() {
return IntegrationFlows
.from(Http.inboundChannelAdapter("numbers").get())
.scatterGather(s -> s
.applySequence(true)
.re
浏览 69提问于2021-07-16得票数 0
我正在尝试将下面的spring集成示例转换为Java版本。
我们需要稍微修改这个项目的版本才能在生产环境中工作。我的问题是，在启动应用程序时，我一直会得到以下异常。
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'httpInboundGateway' defined in org.springframework.platform.proxy.TunnelApplication: Bean instantiation via factory metho
浏览 3提问于2017-02-06得票数 0
回答已采纳
我有一个基于的应用程序，该应用程序的一部分具有以下配置。
upgrade在4.3.10.RELEASE版本中运行良好，但现在我正试图将版本升级到5.1.5.RELEASE，并且应用程序无法从下面提到的例外开始。
我能够解决更改配置的问题，但我想知道为什么要更改这个配置。
在4.3.10中工作的旧配置：
@Bean
public IntegrationFlow mainFlow(@Qualifier("initChannel") PublishSubscribeChannel inboundChannel, TaskExecutor taskExecutor,
浏览 4提问于2020-09-21得票数 0
回答已采纳
在流程定义中，我一定遗漏了一些非常基本的东西。得到这个错误
is a one-way 'MessageHandler' and it isn't appropriate to configure 'outputChannel'. This is the end of the integration flow.
我的理论是，由于适配器是单向组件，因此在流程的句柄步骤中没有生成输出。这就是为什么这会导致运行时错误。但是，不知道如何定义这个简单的流。
代码：
@Autowired
private JmsMessagingTemplate jmsMessagin
浏览 3提问于2016-01-21得票数 2
回答已采纳
由于春季集成依赖关系，我们在使用logConsumer函数时遇到了问题。请帮我查一下。
应用程序启动失败
描述：
试图调用不存在的方法。这一企图是在以下地点进行的：
org.springframework.cloud.fn.consumer.log.LogConsumerConfiguration.logConsumerFlow(LogConsumerConfiguration.java:46)
不存在以下方法：
org.springframework.integration.dsl.IntegrationFlowBuilder.log(Lorg/springframework/integ
浏览 2提问于2021-09-25得票数 0
回答已采纳
我使用的是Spring Cloud Streams和com.azure.spring:azure-spring-cloud-stream-binder-eventhubs:2.8.0，，我使用的是Supplier。
它适用于Spring boot 2.3.12.RELEASE。
但是，如果我转到spring boot版本>= 2.4.0，则会得到以下错误：
An attempt was made to call a method that does not exist. The attempt was made from the following location:
org.
浏览 1提问于2021-09-10得票数 1
我已经使用最新的可用版本设置了一个新的Spring Boot + Spring Integration + Spring Integration Java DSL项目。项目构建得很好，但是，当我运行应用程序时，我得到：
Caused by: java.lang.NoSuchMethodError: org.springframework.integration.dsl.StandardIntegrationFlow.isRegisterComponents()Z
at org.springframework.integration.dsl.config.IntegrationFlowB
浏览 13提问于2018-02-13得票数 2
回答已采纳
我在这个版本中使用spring集成和java依赖关系。
spring-integration-JDBC-5.0.0M6
弹簧-集成-ws- 5.0.0M6
春季-整合-http- 5.0.0M6
弹簧-集成-jmx- 5.0.0M6
弹簧-集成-核心- 5.0.0M6
java 1.2.2RELEASE
由于新的JdbcMetadataStore，我必须使用5.0.0M6版本。
上周，我使用了SpringIntegration4.3.11RELEASE和java-dsl-1.2.2RELEASE，我的应用程序开始工作。
升级过程之后，将引发此运行时异常：
Cau
浏览 4提问于2017-09-08得票数 1
回答已采纳
1回答
我有一个要求，解压缩，文件和处理其内容。在zip文件中，可以有两种类型的文件单独或公司。它可以通过文件名来区分。在处理完所有文件后，它应该调用另一个程序模块，并将处理后的文件存档到不同的位置。希望使用Spring集成来实现同样的功能。我试图通过下面的代码来实现这一点，但是它在基于文件名的路由过程中产生了问题。我使用的是JDK 8，Spring 5
.<File, Boolean>route(new Function<File, Boolean>() {
@Override
public B
浏览 1提问于2018-08-29得票数 1
回答已采纳
我正在用一个新的spring集成版本测试我现有的应用程序。不幸的是，我得到了一个意外的异常，如下所示：
Caused by: java.lang.UnsupportedOperationException: null
at org.springframework.integration.dsl.StandardIntegrationFlow.configure(StandardIntegrationFlow.java:64) ~[spring-integration-java-dsl-1.2.1.RELEASE.jar:na]
at org.springframework.in
浏览 3提问于2017-01-27得票数 3
回答已采纳
1回答
我试图使用spring-integration-dsl-groovy，运行一个简单的spring应用程序，但是我得到了以下错误
org.springframework.web.util.NestedServletException:处理失败；嵌套异常为java.lang.NoClassDefFoundError: org/Message框架/integration/Message
有谁可以帮我？
这是我的密码
@RestController
class SampleController{
@RequestMapping("/welcome")
Stri
浏览 2提问于2015-06-04得票数 1
我正在使用Spring Integration，并且正在使用文件。我使用提供的DSL来处理我的文件。在我的集成流结束时，我使用Files.outboundGateway(...)将结果输出到一个新文件。然而，我一直收到下面的错误no output-channel or replyChannel header available。根据这篇文章底部的帖子，解决方案是将预期的回复设置为false，但是，我如何使用DSL做到这一点呢？ 下面显示了我在集成流的最后一部分中执行的写入文件的操作。 .handle(Files.outboundGateway(new File(outputFilePath)
浏览 28提问于2021-06-30得票数 0
回答已采纳
我在用
spring-integration-java-dsl-1.2.3.RELEASE
spring-integration-ip-4.3.17.RELEASE
spring-integration-http-4.3.17.RELEASE
给定此代码以动态生成TCP连接。我定义了ReveiverAdapter和SenderAdapter。
IntegrationFlow ifr = existsConnection(connectionId);
if (ifr == null) {
TcpNetClientConnectionFactory cf
浏览 0提问于2018-12-19得票数 0
1回答
使用java spring集成编写了下面的代码来读取gmail中的电子邮件。如日志所示，与gmail的连接已经形成，但是在新的电子邮件上，它不读取或不进入handle()方法。请帮帮忙。
o.s.i.m.AbstractMailReceiver -尝试从文件夹收件箱接收邮件
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.s
浏览 10提问于2022-03-03得票数 0
回答已采纳
1回答
我在Spring集成库中使用DSL和Lambdas，遇到了一个奇怪的问题。
我试图构建一个将文件数据拆分为换行符的IntegrationFlow。当我将lambda表达式内联给构建器时，它工作得很好：
return IntegrationFlows.from(this.inboundStreamingMessageSource())
.transform(new StreamTransformer("UTF-8"))
.split(s->s.applySequence(true).get().getT2().setDelimiters(&#
浏览 0提问于2018-08-02得票数 0
回答已采纳
我有一个int-aws:sqs-message-driven-channel-adapter，如果设置errorChannel，下游的异常就会出现。
但是，当我不设置errorChannel时，异常不会被记录。它不属于预期的errorChannel。有没有办法，这样的异常至少会被记录下来？是否存在可以简单记录此类错误的默认errorlogger？
更新
按照注释发布XML和DSL配置。在持久化层中通过为error上的@NotBlank字段设置null来模拟ServiceObject。
<?xml version="1.0" encoding="UTF-8"
浏览 2提问于2021-04-21得票数 1
回答已采纳
使用Spring、Integration和DSL尝试一个非常基本的JMS接收器。我曾经研究过基于的XML，但对Spring和DSL来说还是个新手。
到目前为止，这是一个代码示例。
@SpringBootApplication
@IntegrationComponentScan
@EnableJms
public class JmsReceiver {
static String mailboxDestination = "RETRY.QUEUE";
@Configuration
@EnableJms
@IntegrationComponen
浏览 5提问于2016-01-08得票数 4
回答已采纳
我开发了一个自定义的动态FTP组件来处理spring集成dsl。该组件在spring-boot 1.3.0上运行良好。然而，我不得不在我的一些集成中更新spring-boot，以使用屏障dsl功能，版本为1.5.6。
从现在开始，我会收到以下堆栈跟踪的警告，尽管组件仍然可以工作：
pool-4-thread-1] o.s.i.expression.ExpressionUtils : Creating EvaluationContext with no beanFactory
java.lang.RuntimeException: No beanFactory
at org.s
浏览 105提问于2018-08-16得票数 3
我使用Spring云流读取文件，使用文件拆分器进行拆分，并使用DSL样式将每一行作为消息发出，文件m读取有一个标题行，只是想知道在读取之前/之后是否有一种简单的跳过标题行的方法。
任何帮助都是非常感谢的。
下面是我的拆分器和integrationFlow的样子：
enter code here
return IntegrationFlows
.from("....")
.split(Files.splitter(true, true)/
.charset(StandardCharsets.UTF_8)
浏览 2提问于2017-08-29得票数 1
回答已采纳
我使用了最新的，并在消费者配置上卡住了。
这是我的使用者配置：
@Configuration
public static class ConsumerConfiguration {
@Autowired
private KafkaConfig kafkaConfig;
private Log log = LogFactory.getLog(getClass());
@Bean
public ConsumerFactory<String, String> consumerFactory() {
Map<String,
浏览 2提问于2016-09-21得票数 3
回答已采纳
1回答
我是Spring的新手，我正在尝试开发一个应用程序，该应用程序简单地(1)轮询一个扩展名为.dat的新文件，其中包含csv格式的数据(2)为每一行初始化类RecordDTO的域POJO对象，最后(3)将该对象作为有效负载发送到带有POST的REST服务。
为此，我尝试使用Java进行Spring集成。
我遇到的问题是以下VerifyError / HttpRequestExecutingMessageHandler overrides final method onInit.异常。
2016-07-22 10:01:38.965 ERROR 4460 --- [ main]
浏览 3提问于2016-07-22得票数 0
回答已采纳
我有一个将byte[]有效负载转换为MyClass有效负载的处理器：
@Slf4j
@EnableBinding(Processor.class)
public class MyDecoder {
@ServiceActivator(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT)
public MyClass decode(final byte[] payload) {
MyClass decoded = doStuff(payload);
if (decode
浏览 123提问于2017-01-21得票数 2
回答已采纳
1回答
下面的代码也可以在的答案中找到，当我试图从RabbitMQ切换到Kafka时，我遇到了以下异常：
org.springframework.messaging.MessageHandlingException: Missing header 'foo' for method parameter type [class java.lang.String]
at org.springframework.messaging.handler.annotation.support.HeaderMethodArgumentResolver.handleMissingValue(Hea
浏览 1提问于2018-02-05得票数 1
回答已采纳
我有一个Spring Integration的问题。我使用的是Spring Boot 1.4.0.RELEASE，Spring Integration 4.3.1.RELEASE，Spring Integration DSL 1.2.0.M1。
我想要做的是：
我正在编写一个应用程序，它将从FTP和本地文件系统读取文件(使用入站通道适配器)，将文件传输到本地工作目录(使用文件出站网关)，处理这些文件，然后将它们移动到最终目的地(文件出站网关/适配器)。
编辑:最初的问题源于OutboundGateway的错误使用。有关我做错了什么的详细信息，请查看编辑历史记录。
我在连接一个需要来自消息头的信
浏览 5提问于2016-08-19得票数 4
回答已采纳
我使用Spring Integration，Java DSL (release 1.1.3)，我的org.springframework.integration.dsl.IntegrationFlow定义如下
return IntegrationFlows.from(messageProducerSpec)
.handle(handler)
.handle(aggregator)
.handle(endpoint)
.get();
}
messageProducerSpec是org
浏览 6提问于2016-09-20得票数 4
回答已采纳
我跟着这个医生
并添加maven适当性：
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-sftp</artifactId>
<version>5.0.0.M6</version>
</dependency>
<dependency>
<groupId>org.springframework
浏览 1提问于2017-10-13得票数 2
回答已采纳
2回答
卡夫卡不起作用
、、
我试图探索使用Kafka和Spring的Spring集成。我正在学习本教程
我正在使用该文档中提供的依赖项，但我得到了以下异常
Caused by: org.xml.sax.SAXParseException: cvc-complex-type.3.2.2: Attribute 'compression-codec' is not allowed to appear in element 'int-kafka:producer-configuration'.
我认为这是一个jar不匹配的问题，但我无法解决它，我试图改变版本很多，但组合并不适合我。请找到我下面的g
浏览 6提问于2017-05-19得票数 0
回答已采纳
1回答
当channelTransacted(true)出现问题而不是请求时，如何设置侦听器容器将消息抛到死信队列中？当我不使用channelTransacted时，一切正常，我可以在死信队列中看到消息。
@Bean(name = "amqpInboundEsignRequest")
public IntegrationFlow amqpInbound(ConnectionFactory connectionFactory, PlatformTransactionManager transactionManager) {
return IntegrationFlows.from
浏览 0提问于2018-02-21得票数 0
回答已采纳
1回答
我正在从1.x迁移到springBootVersion = '2.2.10.RELEASE‘，当我针对它进行编译时，我有spring-integration-core-5.2.8.RELEASE.jar，但我找不到它。 import org.springframework.integration.dsl.amqp.Amqp; 文档显示，由于重复声明，我不需要声明dsl包。我是不是遗漏了什么？
浏览 12提问于2020-10-17得票数 0
我正在尝试连接两个队列通道(由JDBC支持)。
@Configuration
public class DemoIntegration {
@Bean
public IntegrationFlow flow(MessageChannel firstJDBCChannel,
MessageChannel secondJDBCChannel) {
return IntegrationFlows.from(firstJDBCChannel)
.bridge(bridgeHa
浏览 8提问于2017-12-09得票数 0
回答已采纳
下面是一个坏了但可执行的示例代码：
@Bean
IntegrationFlow testFlow() {
return IntegrationFlows
.from(Http.inboundChannelAdapter("test")
.requestMapping(mapping -> mapping.methods(HttpMethod.GET))
.get())
.scatterGather(
浏览 9提问于2021-07-13得票数 2
回答已采纳
我已经为Spring Integration编写了基于Java DSL文档的代码。当我运行代码时，我一直收到以下警告，即使日志还显示消息已成功传递给两个订阅者。
2021-03-04 17:21:25.589 WARN 46929 --- [enerContainer-1] bleJmsChannel$DispatchingMessageListener : Dispatcher has no subscribers for jms-channel 'application.jmsPublishSubscribeChannel'.
org.springframework.i
浏览 48提问于2021-03-05得票数 1
回答已采纳
我正在从学习Spring集成，并且我知道如何在收到消息时启动作业。现在，我想获得消息的名称和路径(这是一个文件)。下面是我的工作代码。但是，如果取消对setFileParameterName方法的注释，则会得到以下异常：
java.lang.IllegalArgumentException: Found ambiguous parameter type [class java.lang.String] for method match: [public void com.example.batchprocessing.FileMessageToJobRequest.setFileParamet
浏览 8提问于2020-04-08得票数 0
回答已采纳
我将Spring boot版本从2.0.5.RELEASE升级到2.1.8.RELEASE (因此Spring Integration从5.0升级到5.1)，集成流程中的自动类型转换不再起作用。我习惯于定义一组@IntegrationConverter组件，并在集成流代码中使用transform(Type.class, p -> p)操作进行自动转换，但在新版本中，它似乎被打破了。 <?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache
浏览 51提问于2019-09-13得票数 7
回答已采纳
1回答
对于Spring Integration DSL的文件写入支持，有没有什么可行的例子？我找不到任何关于DSL实现的东西(例如，集成流中的handle()步骤，等等)谢谢。
浏览 4提问于2018-05-30得票数 1
当试图向http出站网关发送请求时，我收到了以下错误。在得到响应后，我将json有效负载转换为我所读过的其他帖子中的对象列表--这可能是服务激活器或转换器的问题。我还在努力弄清楚EIP和SI的情况。
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'httpPostAtms' defined in class path resource [com/backbase/atm/config/InfrastructorConfig.class]: Be
浏览 0提问于2017-07-05得票数 1
回答已采纳
1回答
我正在创建一个新的流，并从几乎为空的定义开始
@Bean
public IntegrationFlow routerFlow() {
return IntegrationFlows
.from(routerInputChannel())
.channel(routerOutputChannel())
.get();
}
到目前一切尚好。但是如果我添加简单的wireTap行
@Bean
public IntegrationFlow routerFlow() {
return IntegrationFlows
浏览 1提问于2017-07-17得票数 2
回答已采纳
我使用的是Spring Integration Java DSL v1.2.2，按照一些示例，我尝试编写一段代码来轮询文件夹
return IntegrationFlows
.from(Files.inboundAdapter(new File("/tmp/foo")))
.handle((p, h) -> fileProcessor.process(p))
.get();
无法编译此代码，因为
"Cannot resolve method 'from(org.springfr
浏览 2提问于2017-06-13得票数 0
回答已采纳
官方Spring Integration DSL参考文档在https://docs.spring.io/spring-integration/reference/html/dsl.html#java-dsl的第一部分中提供了以下代码示例 @Configuration
@EnableIntegration
public class MyConfiguration {
@Bean
public AtomicInteger integerSource() {
return new AtomicInteger();
}
@Bean
publ
浏览 31提问于2021-07-16得票数 1
回答已采纳
1回答
对Spring请求的响应
、、、、
我试图使用Spring集成网关将rest端点请求/响应与Spring云流连接起来。下面的代码适用于第一个rest调用，但随后的调用不起作用。我知道spring云流是用于消息传递/异步操作的。但是这是一个实际的场景，在这个场景中，您需要一个请求/响应同步。
SpringBootApplication
package com.example.restgateway;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
im
浏览 0提问于2018-06-07得票数 0
这是build.gradle文件。我已经删除了评论和敏感数据。仍然收到"missing EmbeddedServletContainerFactory Bean“错误。
buildscript {
ext {
springBootVersion = '1.5.9.RELEASE'
}
repositories {
jcenter()
mavenCentral()
maven { url "https://repo.spring.io/snapshot" }
浏览 6提问于2017-12-19得票数 0
我正在用DSL编写basic-amqp example (https://github.com/spring-projects/spring-integration-samples/blob/master/basic/amqp/src/main/resources/META-INF/spring/integration/spring-integration-context.xml)的示例代码 @Bean
public IntegrationFlow receiveGreetingFromGreetingQueueToConsole(ConnectionFactory connectionFa
浏览 12提问于2020-07-17得票数 0
回答已采纳
因此，Spring Integration 5引入了入站通道的目录扫描器的概念，我非常希望将其用于我的ftp通道。 但是，我不确定如何使用Java DSL来配置它。docs说我可以用XML语言在scanner inbound-channel-adapter上设置扫描仪。但是，我使用的是Spring Integration DSL via IntegrationFlow，在使用这种方法时，我似乎无法设置这个目录扫描器…… 这是真的吗？有没有办法用IntegrationFlow设置目录扫描器？我知道我可以使用更正式的Java Config方法，但我不希望这样做，因为那会有很多工作要做。
浏览 15提问于2019-02-26得票数 1
回答已采纳
1回答
我正在尝试运行我的，在tomcat中使用Spring (所以我将它打包为war)。
我能够成功地部署war，但它没有监听给定队列上的消息。当我将它作为IDE中的应用程序启动时，一切都很好。有人能指出我在下面的代码中遗漏了什么，或者应该以另一种方式部署吗？
@Configuration
@SpringBootApplication
@IntegrationComponentScan
@EnableAutoConfiguration
@EnableIntegration
public class SpringIntegrationApplication {
public static void
浏览 2提问于2016-07-19得票数 0
回答已采纳
Spring Integration Java Dsl中有没有一种方法可以做到这一点：
@Bean
IntegrationFlow serviceFlow() {
return IntegrationFlows
.from("inputChannel")
.handle(File.class, (p,h) -> someService.someMethod(p))
.channel("someChannel")
.get();
}
如下所示：
@Bean
IntegrationFlow
浏览 0提问于2015-06-04得票数 1
如何使用Spring Integration DSL创建XPath拆分器？与此对应的DSL是什么：
<!-- Split the order into items creating a new message for each item node -->
<int-xml:xpath-splitter id="orderItemSplitter"
input-channel="orderChannel"
output-channel="orderItemsCha
浏览 0提问于2016-03-22得票数 1
在我们的一个生产应用程序中，我们有一个相当复杂的spring集成-amqp用例，而且我们已经看到一些"org.springframework.integration.MessageDispatchingException:调度程序在启动时没有订阅者的例外。在启动时出现初始错误后，我们不再看到来自相同组件的这些异常。这看起来就像是依赖AMQP出站适配器并在生命周期早期使用它们的组件上的某种启动竞争条件。
我可以通过调用一个网关来再现这一点，该网关在PostConstruct方法中发送到连接到出站适配器的通道。
配置：
package gadams;
import org.springf
浏览 4提问于2016-06-03得票数 2
回答已采纳
1回答
我在这里做一个分散的收集流。在流的末尾，我想打印从应答通道到控制台的消息。这里有3个API调用，其中2个是GET调用，1个是POST调用(POST调用正在执行一些数据库操作)。所有API都在运行并得到结果，但我无法打印消息。
//Configuration class
package com.lbg.scattergather.configuration;
import com.lbg.scattergather.model.Company;
import org.springframework.context.annotation.Bean;
import org.springframe
浏览 7提问于2022-06-19得票数 0
1回答
我目前正在运行Spring Edgware.SR2。我正在将服务从RabbitMQ迁移到Kafka，在运行关于Zipkin主题(即kafka-console-consumer.sh --new-consumer --bootstrap-server localhost:9092 --topic zipkin --from-beginning)的kafka-console-console. the时，我没有看到任何zipkin跟踪。因此，我当然不会在Zipkin UI中看到任何跟踪信息。
以下是我作为生产者服务的一部分的依赖关系：
<parent>
<groupId&g
浏览 0提问于2018-02-12得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
