无需手动设置系统属性，如何正确配置KafkaClient？

问题原因 #

你的错误源于**sasl.jaas.config配置项误用了JAAS文件路径**——Kafka客户端并不会通过这个配置项读取外部JAAS文件，它的作用是直接提供JAAS登录模块的完整配置内容；而指定JAAS文件路径的方式是通过系统属性java.security.auth.login.config，这正是你不想使用的方式。

无需设置系统属性的解决方法 #

可以直接将JAAS配置内容内嵌到客户端配置中，无需依赖单独的kafka_jaas.conf文件，也不用手动设置系统属性：

修改后的客户端配置 #

client-config {
    bootstrap.servers = ${bootstrap.servers}
    schema.registry.url = ${schema.registry.url}
    security{
        protocol = "SASL_PLAINTEXT"
        sasl.mechanism = "OAUTHBEARER"
        # 直接内嵌JAAS配置内容，注意双引号转义
        sasl.jaas.config = "org.apache.kafka.common.security.plain.PlainLoginModule required oauth.token.endpoint.uri=\"uri\" oauth.client.id=\"uid\" oauth.client.secret=\"secret\";"
    }
}

如果使用HOCON格式，也可以用单引号包裹配置内容，避免内部双引号的转义：

sasl.jaas.config = 'org.apache.kafka.common.security.plain.PlainLoginModule required oauth.token.endpoint.uri="uri" oauth.client.id="uid" oauth.client.secret="secret";'

补充说明 #

若你坚持要保留单独的kafka_jaas.conf文件，仅靠Kafka原生客户端配置无法实现，必须通过系统属性或代码加载文件。但上述内嵌配置的方式已经完全满足“仅通过配置文件解决问题”的需求。

内容的提问来源于stack exchange，提问作者A. Vasyukhin