Alexandre GRIFFAUT created KAFKA-7226:
-----------------------------------------
Summary: kafka-console-consumer.sh doesn't use security.protocol
provided in config file
Key: KAFKA-7226
URL: https://issues.apache.org/jira/browse/KAFKA-7226
Project: Kafka
Issue Type: Bug
Components: producer
Affects Versions: 1.0.0
Reporter: Alexandre GRIFFAUT
It is confusing that kafka-console-consumer.sh doesn't read security.protocol
when provided in config file with --producer.config, wheras
kafka-console-consumer.sh does...
With debug activated:
$ /usr/hdp/2.6.5.0-292/kafka/bin/kafka-console-producer.sh --broker-list
$(hostname):6668 --topic test --producer.config
/etc/kafka/ssl/kafka.client.properties
[2018-08-01 14:17:18,505] INFO ProducerConfig values:
...
security.protocol = PLAINTEXT
...
> abc
..
java.io.EOFException
at
org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:147)
at
org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:93)
at
org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:235)
at
org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:196)
at
org.apache.kafka.common.network.Selector.attemptRead(Selector.java:538)
at
org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:482)
at org.apache.kafka.common.network.Selector.poll(Selector.java:412)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:460)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:239)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:163)
at java.lang.Thread.run(Thread.java:745)
...
The only way produce with SSL, is to use --security-protocol SSL
kafka-console-consumer.sh correctly read security.protocol from config file
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
