时间戳

首页 > 解决方案 > KafkaTransactionManager 超时

spring-boot - KafkaTransactionManager 超时

问题描述

我试图为org.springframework.kafka.transaction.KafkaTransactionManager via @Transactional( org.springframework.transaction.annotation.Transactional) 配置超时。

@Bean
@Transactional(timeout = 40)
public Function<JsonNode, JsonNode> process() {
    return e -> {
        //do something
        return e;
    };
}

我的处理器正在使用 Spring Cloud Stream Kafka

但这似乎不起作用。我搜索org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder并看到事务管理器不是 Bean。这与不活动超时有什么关系吗？

有什么解决方案吗？

标签： spring-bootspring-cloud-stream-binder-kafka

解决方案

推荐阅读