kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Alexandre GRIFFAUT (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-7226) kafka-console-consumer.sh doesn't use security.protocol provided in config file
Date Wed, 01 Aug 2018 12:25:00 GMT
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)

Mime
View raw message