Spring Cloud Stream Kafka活页夹配置在运行时更新

Question

我正在使用Spring云流和Kafka绑定器使用SASL连接到Kafka集群。SASL配置如下所示：

spring.cloud.stream.kafka.binder.configuration.sasl.mechanism=SCRAM-SHA-512
spring.cloud.stream.kafka.binder.configuration.sasl.jaas.config= .... required username="..." password="..."
spring.cloud.stream.kafka.binder.configuration.security.protocol=SASL_SSL

我想以编程方式/在运行时更新用户名和密码，如何在Spring Cloud Stream中使用Spring Kafka binders做到这一点？

旁注：使用BinderFactory，我可以在其hashmap中看到这些配置，但我想知道如何在运行时更新配置，以便这些更改也反映在连接中？

@Autowired
BinderFactory binderFactory

....

public void foo()
{
    KafkaMessageChannelBinder k = (KafkaMessageChannelBinder)binderFactory.getBinder(null, MessageChannel.class);
    // Using debugger I inspected k.configurationProperties.configuration which has the SASL properties I need to update
}

Answer 1

我昨天遇到了这个问题，花了大约3-4个小时来研究如何使用Spring Kafka binders以编程方式更新Spring Cloud Stream中的用户名和密码，因为人们不能/不应该在Git中存储密码。（Spring Boot版本2.5.2）重写bean KafkaBinderConfigurationProperties有效。

@Bean
@Primary
public KafkaBinderConfigurationProperties kafkaBinderConfigurationProperties(KafkaBinderConfigurationProperties properties) {
    String saslJaasConfigString = "org.apache.kafka.common.security.scram.ScramLoginModule required username=${USERNAME_FROM_EXTERNAL_SYSTEM_LIKE_VAULT} password=${PASSWORD_FROM_EXTERNAL_SYSTEM_LIKE_VAULT}"
    Map<String, String> configMap = properties.getConfiguration();
    configMap.put(SaslConfigs.SASL_JAAS_CONFIG, saslJaasConfigString);
    return properties;
}

Answer 2

可以使用配置提供jaas用户名和密码，这也意味着可以在运行时使用相同的属性覆盖它们。

以下是一个示例：https://github.com/spring-cloud/spring-cloud-stream-samples/blob/master/multi-binder-samples/kafka-multi-binder-jaas/src/main/resources/application.yml#L26

在运行时，您可以覆盖应用程序中设置的值。属性。例如，如果您使用java-jar运行应用程序，您可以简单地传递属性：spring。云流动Kafka。粘合剂jaas。选项。用户名。然后，此新值将在应用程序运行期间生效。