[ 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)