webMethods

Hi All

We are trying to setup kafka adapter connection in 10.15 and we are stuck with how to setup the kerberos authentication and jaas file config.

Where do we define that and how to define that. Target system has given us the

security.protocol= SASL_PLAINTEXT
sasl.kerberos.service.name=kafka
ssl.truststore.location= /abcTrustore.jks
ssl.truststore.password= *********

KafkaClient {
com.sun.security.auth.module.Krb5LoginModule required
useKeyTab=true
keyTab=“abc/def/test.keytab”
principal="user@domain.com";
};

We have placed the kafka jars and setup the values as below

In logs too nothing much is written. Asked the kafka team about any control flag they said that is not needed.
Error

[ADA.507.1001] Resource Connection Exception:
org.apache.kafka.common.KafkaException: Failed to construct kafka producer: Login module control flag is not available in the JAAS config

Apache Kafka® SASL Producer Connection

Bootstrap Servers - server1,server2,server3
value serializer class - com.wm.adapter.wmkafka.idata.IDataSerializer
Key Serializer Class - com.wm.adapter.wmkafka.idata.IDataSerializer
Security Protocol - SASL_PLAINTEXT
Kerberos Service Name - kafka
JAAS Config - copy pasted above JAAS and also tried to place in a location and refer the file
Trustore Alias - KafkaTrustStore(Created a new trust store and called it here)
Kafka - 11+(tried others too)

Hi ,

are you using WmKafkaAdapter or do you try to connect by using a different approach?

Regards,
Holger

Hi Holger

We are using WmKafkaAdapter

Regards
Abhijith

Any one worked with this before?

If you need an urgent support, you can create a ticket on empower. My company doesn’t have WmKafkaAdapter, it may take a while for someone who has that adapter notice this topic and reply. It is not a common adapter.

Forgot to update. It worked now.

Kafka team has provided us with the krb5.conf file which is a kerberous file and we have set the kerberous file location under

Security>Kerbros and filled the location details.

And after filling all the connection details in the Adapter connection screen the connection got enabled and we were able to send the data to Kafka…

Regards
Abhijith