The output below is actually from having
security.protocol=SASL_PLAINTEXT
in producer.properties.
Actual error point I believe is:
Caused by: java.lang.SecurityException: java.io.IOException:
Configuration Error:
Line 5: expected [option key]
at sun.security.provider.ConfigFile$Spi.<init>(ConfigFile.java:137)
Pekka
On 10/03/17 17:21, Ted Yu wrote:
I think in producer.properties you should use:
security.protocol=SASL_PLAINTEXT
FYI
On Tue, Oct 3, 2017 at 7:17 AM, Pekka Sarnila <sarn...@adit.fi> wrote:
Hi,
kafka_2.11-0.11.0.0
If I try to give --security-protocol xyz (xyz any value e.g.
SASL_PLAINTEXT, PLAINTEXTSASL, SASL_SSL) I get error
security-protocol is not a recognized option
Also having security.protocol=xyz in producer.properties gives error
org.apache.kafka.common.KafkaException: Failed to construct kafka producer
at org.apache.kafka.clients.producer.KafkaProducer.<init>(Kafka
Producer.java:415)
at org.apache.kafka.clients.producer.KafkaProducer.<init>(Kafka
Producer.java:287)
at kafka.producer.NewShinyProducer.<init>(BaseProducer.scala:40)
at kafka.tools.ConsoleProducer$.main(ConsoleProducer.scala:48)
at kafka.tools.ConsoleProducer.main(ConsoleProducer.scala)
Caused by: java.lang.SecurityException: java.io.IOException: Configuration
Error:
Line 5: expected [option key]
at sun.security.provider.ConfigFile$Spi.<init>(ConfigFile.java:
137)
at sun.security.provider.ConfigFile.<init>(ConfigFile.java:102)
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(Native
ConstructorAccessorImpl.java:62)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(De
legatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at java.lang.Class.newInstance(Class.java:442)
at javax.security.auth.login.Configuration$2.run(Configuration.
java:255)
at javax.security.auth.login.Configuration$2.run(Configuration.
java:247)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.login.Configuration.getConfiguration(Con
figuration.java:246)
at org.apache.kafka.common.security.JaasContext.defaultContext(
JaasContext.java:112)
at org.apache.kafka.common.security.JaasContext.load(JaasContex
t.java:96)
at org.apache.kafka.common.security.JaasContext.load(JaasContex
t.java:78)
at org.apache.kafka.common.network.ChannelBuilders.create(
ChannelBuilders.java:100)
at org.apache.kafka.common.network.ChannelBuilders.clientChanne
lBuilder(ChannelBuilders.java:58)
at org.apache.kafka.clients.ClientUtils.createChannelBuilder(Cl
ientUtils.java:88)
at org.apache.kafka.clients.producer.KafkaProducer.<init>(Kafka
Producer.java:374)
... 4 more
Caused by: java.io.IOException: Configuration Error:
Line 5: expected [option key]
at sun.security.provider.ConfigFile$Spi.ioException(ConfigFile.
java:666)
at sun.security.provider.ConfigFile$Spi.match(ConfigFile.java:562)
at sun.security.provider.ConfigFile$Spi.parseLoginEntry(
ConfigFile.java:477)
at sun.security.provider.ConfigFile$Spi.readConfig(ConfigFile.
java:427)
at sun.security.provider.ConfigFile$Spi.init(ConfigFile.java:329)
at sun.security.provider.ConfigFile$Spi.init(ConfigFile.java:271)
at sun.security.provider.ConfigFile$Spi.<init>(ConfigFile.java:
135)
... 21 more
Pekka
