spring-cloud-stream-Kafka生产者前缀每个节点唯一

问题描述

我想使用输出通道在仅生产者事务中(而不是在读写过程中)向Kafka主题发送消息。 我阅读了有关StackOverflow(Spring cloud stream kafka transactions in producer side)的文档和另一个主题

问题是我需要为每个节点设置唯一的transactionIdPrefix。 有什么建议怎么做吗?

解决方法

这是一种方法...

@Component
class TxIdCustomizer implements EnvironmentAware {

    @Override
    public void setEnvironment(Environment environment) {
        Properties properties = new Properties();
        properties.setProperty("spring.cloud.stream.kafka.binder.transaction.transactionIdPrefix",UUID.randomUUID().toString());
        ((StandardEnvironment) environment).getPropertySources()
                .addLast(new PropertiesPropertySource("txId",properties));
    }

}