Kafka交易生产者的跟踪无法工作。

若要使Sleuth跟踪适用于Kafka交易生产者，请确保设置以下属性：

spring.kafka.producer.transaction-id-prefix=myTxn

然后，您可以使用以下代码示例来创建一个生产者，并在其中设置Sleuth：

@Bean
public KafkaTemplate<String, String> kafkaTemplate(ProducerFactory<String, String> producerFactory) {
    KafkaTemplate<String, String> kafkaTemplate = new KafkaTemplate<>(producerFactory);
    TracingProducerInterceptor interceptor = new TracingProducerInterceptor(tracer);
    kafkaTemplate.setProducerListener(new TracingProducerListener(tracer));
    kafkaTemplate.setInterceptors(Collections.singletonList(interceptor));
    return kafkaTemplate;
}

@Bean
public ProducerFactory<String, String> producerFactory() {
    Map<String, Object> configProps = new HashMap<>();
    configProps.put(
      ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,
      bootstrapAddress);
    configProps.put(
      ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
      StringSerializer.class);
    configProps.put(
      ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
      StringSerializer.class);
    configProps.put(
      ProducerConfig.TRANSACTION_ID_CONFIG, "myTxn");

    return new DefaultKafkaProducerFactory<>(configProps);
}

这将确保你的生产者在执行事务时正确跟踪。