Hi @early-lamp-41924, Thanks for the pointers given in the above thread. I built a custom image for

kafka-setup-job

to pickup

SASL_SSL

related properties via Helm Chart, I am seeing this error -

[main] ERROR io.confluent.admin.utils.cli.KafkaReadyCommand - Error while running kafka-ready.                                                                                                                                                             
│ org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient                                                                                                                                                                              
│     at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:535)                                                                                                                                                           
│     at org.apache.kafka.clients.admin.Admin.create(Admin.java:75)                                                                                                                                                                                          
│     at org.apache.kafka.clients.admin.AdminClient.create(AdminClient.java:49)                                                                                                                                                                              
│     at io.confluent.admin.utils.ClusterStatus.isKafkaReady(ClusterStatus.java:138)                                                                                                                                                                         
│     at io.confluent.admin.utils.cli.KafkaReadyCommand.main(KafkaReadyCommand.java:150)                                                                                                                                                                     
│ Caused by: org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException: unable to find LoginModule class: software.amazon.msk.auth.iam.IAMLoginModule                                                                                 
│     at org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:172)                                                                                                                                                           
│     at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:157)                                                                                                                                                                    
│     at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:73)                                                                                                                                                       
│     at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:105)                                                                                                                                                                     
│     at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:508)

This seems like an exception on the kafka side unfortunately. Can you search for any issues on their github page?

Kafka-setup

container is given by DataHub isnt it? Its mentioned in Configuring Kafka page too about using the method which it says missing, but there is no mention of how to do this from product itself. Just wanted to clarify

Kafka setup simply runs create topics command using the kafka cli tool from the open source kafka image