[
https://issues.apache.org/jira/browse/KAFKA-7226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-7226.
------------------------------
Resolution: Information Provided
Closing the issue related to HDP Kafka distribution.
> 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
> Priority: Minor
>
> 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)
