如何解决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));
}
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。