[
https://issues.apache.org/jira/browse/KAFKA-7226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565681#comment-16565681
]
Manikumar edited comment on KAFKA-7226 at 8/1/18 5:37 PM:
----------------------------------------------------------
looks like the issue is specific to HDP Kafka distribution. Can you raise the
issue with the HDP vendor?
kafka-console-producer.sh script which is part of Apache Kafka release, does
not accept "security-protocol" option. It only accepts "producer.config",
"property" options.
was (Author: omkreddy):
looks like the issue is specific to HDP Kafka distribution. Can you raise the
issue with the HDP vendor?
kafka-console-producer.sh script which is part of Apache Kafka release, does
not accept "--security-protocol" option. It only accepts "--producer.config",
"--property" options.
> 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)
