Question
4
Replies
113
Views
Posted: October 23, 2020
Last activity: October 27, 2020
Help configuring Kafka Instance
I am trying to create a new Kafka instance with username and password authentication. I have the JVM argument Djava.security.auth.login.config pointing to my jaas config file. When I test connectivity, I get the message:
Connection Failed Error connecting to Kafka. Timeout expired while fetching topic metadata
There is nothing in the PegaRULES or ALERT logs to indicate what the issue is.
On which classes can DEBUG be enabled to get a better idea what is failing?
***Edited by Moderator Marissa to update Platform Capability tags****
Not aware of any, unfortunately. However, since 8.4.2, we have provided an enhancement to allow you load standard kafka client properties files when configuring kafka connection instead of using jvm argument. An example is like this - the idea is that you can test connectivity outside pega using the same file to confirm connectivity as a way of troubleshooting - suggest upgrade to the latest (8.4.3) if not already.
sasl.mechanism=PLAIN security.protocol=SASL_PLAINTEXT sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \ username="kafka" \ password="kafka";