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

Question

我想发送一些东西到Kafka主题在生产者(而不是在读写过程中)事务使用输出通道。我在StackOverflow (Spring cloud stream kafka transactions in producer side)上阅读了文档和另一个主题。

问题是我需要为每个节点设置唯一的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));
    }

}