Hello everybody,
I'm facing an issue with Camel 2.25.0 and Spring Boot 2.2.5 (as well with Camel
2.22.1 with Spring Boot 2.0.7) running on OpenJDK 8u242 within Docker (Azure
container instances).
Utilizing the Kafka component I'm producing messages with the following
statement
.recipientList(simple(route.getDestination()+"${header.KafkaTopic}?"+route.getDestinationOptions()))
where route.getDestination() names a bean defined as
<bean id="someKafkaCluster"
class="org.apache.camel.component.kafka.KafkaComponent" primary="true">
<property name="brokers"
value="somehost.azure.confluent.cloud:9092"/>
</bean>
and route.getDestinationOptions() resolves from a YAML file to
"saslMechanism=PLAIN&sslProtocol=TLSv1.2&securityProtocol=SASL_SSL&sslEndpointAlgorithm=https&sslEnabledProtocols=TLSv1.2&saslJaasConfig=org.apache.kafka.common.security.plain.PlainLoginModule
required username=\"username\" password=\"password\";"
Even though the initial login seems to work ("JmsConsumer[testqueue] [0;39m
org.apache.kafka.common.security.authenticator.AbstractLogin - Successfully
logged in")
sending the first message results in
2020-03-24 10:54:40,994 [1;31mERROR [0;39m [35mer-network-thread | producer-1
[0;39m org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1]
Connection to node -1 (somehost.azure.confluent.cloud/255.255.255.255:9092)
failed authentication due to: Authentication failed: Invalid username or
password
The producer logs that it got the Jaas config:
org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values:
...
sasl.jaas.config = [hidden]
The strange thing now is that if I remove the sasljaasConfig from the URI and
copy it to a Jaas config file, wrapped with "KafkaClient { ... }", referenced
via "-Djava.security.auth.login.config=...", everything works fine.
Apparently, user2966021 seems to have at least a very similar issue according
to a comment on StackOverflow:
https://stackoverflow.com/questions/50090226/how-to-implement-camel-kafka-producer-and-consumer-which-is-using-kafka-brokers
The password contains characters + and /, but as I'm using double quoted YAML
strings, I don't expect this to be an issue.
Anybody having any hints for me?
Thanks in advance!
Best Regards
Andreas
Robert Bosch GmbH | Postfach 30 02 20 | 70442 Stuttgart | GERMANY |
www.bosch.com
Registered Office: Stuttgart, Registration Court: Amtsgericht Stuttgart, HRB
14000;
Chairman of the Supervisory Board: Franz Fehrenbach; Managing Directors: Dr.
Volkmar Denner,
Prof. Dr. Stefan Asenkerschbaumer, Dr. Michael Bolle, Dr. Christian Fischer,
Dr. Stefan Hartung,
Dr. Markus Heyn, Harald Kröger, Christoph Kübel, Rolf Najork, Uwe Raschke,
Peter Tyroller
