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

Question

我想使用输出通道在仅生产者（不在读写过程中）事务中向Kafka主题发送一些东西。我在StackOverflow（生产者端的Spring Cloud stream kafka事务）上阅读了留档和另一个主题。

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

Answer 1

这里有一种方法。。。

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

}