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));
    }

}