春云侦探和春云流动力--如何传播跟踪ID？

Question

Spring Cloud Sleuth跟踪头是否像这里描述的RabbitMq和Kafka那样被注入到Spring Cloud Stream Kinesis消息中？我们有一个REST控制器，它在处理POST请求之后，但在向客户机发送响应之前，向Kinesis发送一个Avro消息，该消息使用Spring Cloud Stream Kinesis总结事务。我想确保在REST控制器中启动的跟踪id被传播到Spring Cloud Stream Kinesis消息中，我不确定如何配置它，或者框架是否支持它。当我在处理这个Avro消息的微服务中记录消息和头时，我会看到一个不同的跟踪ID（当然还有span ID）。在REST控制器到Kinesis消息上下文之间的传播似乎没有正确配置和/或工作。

我们目前使用的是Spring Cloudhoxton.sr10、Spring Boot2.3.9.release和Spring Cloud Kinesis2.0.1.release。

顺便说一句，我尝试将Spring Cloud Kinesis升级到2.0.2.release、2.0.3.release和2.0.4.release，但每次升级绑定器时都会遇到错误。我不确定Spring Cloud、Spring Boot和Spring Cloud Stream Kinesis的版本组合是什么。

示例代码

@PostMapping(
      value = "/accountEntry",
      consumes = {MediaType.APPLICATION_JSON_VALUE, MediaType.APPLICATION_XML_VALUE},
      produces = {MediaType.APPLICATION_JSON_VALUE, MediaType.APPLICATION_XML_VALUE})
  public ResponseEntity<Confirmation> createAccountEntry(
      @RequestBody final AccountEntry accountEntry,
      final HttpServletRequest request) {
    final AccountEntryEvent accountEntryEvent =
        new AccountEntryEvent(convertToAvro(accountEntry), AccountEntryEventType.CREATE_ACCOUNT_ENTRY);
    accountEntryChannels
        .accountEntryRequest()
        .send(
            MessageBuilder.withPayload(accountEntryEvent)
                .build());
    final Confirmation confirmation = buildConfirmation();
    final EntityModel<Confirmation> confirmationEntityModel =
        new EntityModel<>(confirmation);
    return new ResponseEntity<>(confirmationEntityModel, HttpStatus.ACCEPTED);
}

// with a brave.Tracer instance autowired, I'm able to obtain the trace id as follows
protected String getTraceId() {
  return tracer.currentSpan().context().traceIdString();
}
  
@Component
public interface AccountEntryChannels {
  @Output("account-entry-request")
  SubscribableChannel accountEntryRequest();
  ...
}

Answer 1

如果您通过StreamBinder或MessageChannel使用它，它应该可以工作；如果您以函数方式使用它(Supplier+BlockingQueue)它不应该，则不支持函数方式。