Konfigurieren Sie den Kafka -Produzenten SASL_JAAS_CONFIG -Fehler bei Verwendung von Env -Variablen ⇐ Java

[Anonymous]

Ich habe die folgende Konfiguration, um mit der Spring -Batch -App zum Thema zu produzieren: < /p>
Map configProps = new HashMap();
configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,bootstrapServers);
configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,JsonSerializer.class);
configProps.put(ProducerConfig.MAX_BLOCK_MS_CONFIG,10000);
configProps.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG,6000);
configProps.put(ProducerConfig.DELIVERY_TIMEOUT_MS_CONFIG,8000);
configProps.put(ProducerConfig.RETRIES_CONFIG,0);
configProps.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SASL_SSL");
configProps.put(SaslConfigs.SASL_MECHANISM, "PLAIN");
configProps.put(SaslConfigs.SASL_JAAS_CONFIG, String.format("%s required username=\"%s\" " + "password=\"%s\";", PlainLoginModule.class.getName(), "UYDUEWWU27LFC2CJ", "yqBcf5BM4rd3X273OsaB6/n7/kuxmRG39+Fr3nVuOdXI/RZ/sM9E6hpqmaAPxCbC"));
< /code>
Dies funktioniert einwandfrei, aber wenn ich versuche, die Env -Variablen für Benutzername und Kennwort in der SASL JAAS -Konfiguration zu erhalten, wie ich es mit Bootstrap -Server mache: < /p>
String username = env.getProperty("spring.bootstrap.kafka.username");
String password = env.getProperty("spring.bootstrap.kafka.password");
configProps.put(SaslConfigs.SASL_JAAS_CONFIG, String.format("%s required username=\"%s\" " + "password=\"%s\";", PlainLoginModule.class.getName(), username, password));
< /code>
Es gibt mir den Fehler "Authentifizierung fehlgeschlagen" beim Senden des Objekts an das Thema Kafka, obwohl die Anmeldung erfolgreich war. Ich habe überprüft, ob der Inhalt jedes String -Formats in den Protokollen gleich ist. Wie ist das möglich?
Danke