SASL JAAS Error

[carlcauchigig]

Hi,

I'm trying to connect the Kafka Manager with a Kafka Cluster having Consumer/Producers requiring SASL_PLAINTEXT while the inter communication between the Kafka Brokers and Zookeeper is Normal/PLAINTEXT without SASL.

The Kafka Manager is constantly creating the following error:

2019-07-29 21:03:59,802 - [INFO] k.m.a.KafkaManagerActor - Updating internal state...
2019-07-29 21:03:59,859 - [INFO] k.m.a.c.KafkaStateActor - SASL Mechanism =SASL_MECHANISM_PLAIN
2019-07-29 21:03:59,859 - [INFO] k.m.a.c.KafkaStateActor - SASL JAAS config=security.protocol=SASLPLAINTEXT key.deserializer=org.apache.kafka.common.serialization.StringDeserializer value.deserializer=org.apache.kafka.common.serialization.StringDeserializer auto.offset.reset=earliest sasl.mechanism=PLAIN sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="XXXX" password="XXXXX";
2019-07-29 21:03:59,860 - [ERROR] k.m.a.c.KafkaStateActor - consumerProperties:{key.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, sasl.mechanism=PLAIN, bootstrap.servers=XXXXXXXXXXXXXX:9093, group.id=kafka.manager.actor.cluster.KafkaStateActor.KafkaTopicOffsetGetter, sasl.jaas.config=security.protocol=SASLPLAINTEXT key.deserializer=org.apache.kafka.common.serialization.StringDeserializer value.deserializer=org.apache.kafka.common.serialization.StringDeserializer auto.offset.reset=earliest sasl.mechanism=PLAIN sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="XXXXX" password="XXXXXX";, value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer, security.protocol=SASL_PLAINTEXT}
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:811)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:659)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:639)
at kafka.manager.actor.cluster.KafkaStateActor$KafkaTopicOffsetGetter.$anonfun$run$21(KafkaStateActor.scala:1489)
at kafka.manager.actor.cluster.KafkaStateActor$KafkaTopicOffsetGetter.$anonfun$run$21$adapted(KafkaStateActor.scala:1467)
at scala.collection.Iterator.foreach(Iterator.scala:941)
at scala.collection.Iterator.foreach$(Iterator.scala:941)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1429)
at scala.collection.MapLike$DefaultKeySet.foreach(MapLike.scala:181)
at kafka.manager.actor.cluster.KafkaStateActor$KafkaTopicOffsetGetter.$anonfun$run$20(KafkaStateActor.scala:1467)
Caused by: java.lang.IllegalArgumentException: Login module control flag is not available in the JAAS config
at org.apache.kafka.common.security.JaasConfig.loginModuleControlFlag(JaasConfig.java:85)
at org.apache.kafka.common.security.JaasConfig.parseAppConfigurationEntry(JaasConfig.java:111)
at org.apache.kafka.common.security.JaasConfig.(JaasConfig.java:63)
at org.apache.kafka.common.security.JaasContext.load(JaasContext.java:90)
at org.apache.kafka.common.security.JaasContext.loadClientContext(JaasContext.java:84)
at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:124)
at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:67)
at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:112)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:726)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:659)
2019-07-29 21:03:59,860 - [ERROR] k.m.a.c.KafkaStateActor - KafkaTopicOffsetGetter exception
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:811)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:659)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:639)
at kafka.manager.actor.cluster.KafkaStateActor$KafkaTopicOffsetGetter.$anonfun$run$21(KafkaStateActor.scala:1489)
at kafka.manager.actor.cluster.KafkaStateActor$KafkaTopicOffsetGetter.$anonfun$run$21$adapted(KafkaStateActor.scala:1467)
at scala.collection.Iterator.foreach(Iterator.scala:941)
at scala.collection.Iterator.foreach$(Iterator.scala:941)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1429)
at scala.collection.MapLike$DefaultKeySet.foreach(MapLike.scala:181)
at kafka.manager.actor.cluster.KafkaStateActor$KafkaTopicOffsetGetter.$anonfun$run$20(KafkaStateActor.scala:1467)
Caused by: java.lang.IllegalArgumentException: Login module control flag is not available in the JAAS config
at org.apache.kafka.common.security.JaasConfig.loginModuleControlFlag(JaasConfig.java:85)
at org.apache.kafka.common.security.JaasConfig.parseAppConfigurationEntry(JaasConfig.java:111)
at org.apache.kafka.common.security.JaasConfig.(JaasConfig.java:63)
at org.apache.kafka.common.security.JaasContext.load(JaasContext.java:90)
at org.apache.kafka.common.security.JaasContext.loadClientContext(JaasContext.java:84)
at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:124)
at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:67)
at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:112)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:726)
at org.apache.kafka.clients.consumer.KafkaConsumer.(KafkaConsumer.java:659)

While most of the things are working fine from the Kafka Manager, it does not display Partition Information - Latest Offset, which are all empty.

I'm using the latest 2.0.0.2 tag.

Any ideas?