[
https://issues.apache.org/jira/browse/KAFKA-6426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16313021#comment-16313021
]
Menaka Madushanka commented on KAFKA-6426:
------------------------------------------
HI Manikumar,
I configured the server.properties file with the SASL_PlAINTEXT for listeners,
and advertised.listeners and in producer and consumer properties. But when I
run the consumer with these configs, I get this error.
{code:java}
[2018-01-05 17:48:41,346] WARN
{kafka.consumer.ConsumerFetcherManager$LeaderFinderThread} -
[group_menaka-ThinkPad-X1-Carbon-3rd-1515154589076-a2c82e5a-leader-finder-thread],
Failed to find leader for Set(sensordata-0)
kafka.common.BrokerEndPointNotAvailableException: End point with security
protocol PLAINTEXT not found for broker 0
at
kafka.client.ClientUtils$$anonfun$getPlaintextBrokerEndPoints$1$$anonfun$apply$5.apply(ClientUtils.scala:146)
at
kafka.client.ClientUtils$$anonfun$getPlaintextBrokerEndPoints$1$$anonfun$apply$5.apply(ClientUtils.scala:146)
at scala.Option.getOrElse(Option.scala:120)
at
kafka.client.ClientUtils$$anonfun$getPlaintextBrokerEndPoints$1.apply(ClientUtils.scala:146)
at
kafka.client.ClientUtils$$anonfun$getPlaintextBrokerEndPoints$1.apply(ClientUtils.scala:142)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
at scala.collection.AbstractTraversable.map(Traversable.scala:105)
at
kafka.client.ClientUtils$.getPlaintextBrokerEndPoints(ClientUtils.scala:142)
at
kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:67)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
{code}
> Kafka SASL/SCRAM authentication does not fail for incorrect username or
> password.
> ---------------------------------------------------------------------------------
>
> Key: KAFKA-6426
> URL: https://issues.apache.org/jira/browse/KAFKA-6426
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.10.2.1
> Environment: Ubuntu 16.04, JDK 1.8, Kafka_2.10-0.10.2.1
> Reporter: Menaka Madushanka
> Attachments: broker-jaas.conf, client-jaas.conf, consumer.properties,
> producer.properties, server.properties
>
>
> Hi,
> I configured Kafka 0.10.2.1 for SASL/SCRAM by following the documentation
> [1].
> But it does work when I use incorrect username or password in the client as
> well.
> I have attached the server.properties, consumer.properties,
> producer.properties, jass config files for broker and client.
> Also, in my producer, I have set
> {{props.put("sasl.mechanism", "SCRAM-SHA-256");}}
> but when running, it shows,
> {{kafka.utils.VerifiableProperties - Property sasl.mechanism is not valid}}
> [1]
> [https://kafka.apache.org/documentation/#security_sasl_scram|https://kafka.apache.org/documentation/#security_sasl_scram]
> Thanks and Regards,
> Menaka
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
