kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "John Chu (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (KAFKA-6510) WARN: Fail to send SSL Close message
Date Wed, 31 Jan 2018 17:04:00 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-6510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

John Chu updated KAFKA-6510:
----------------------------
    Description: 
I have a thread which once in a while is going to list the topics on the Message Hub. But
once in a while, I am getting a :Failed to send SSL Close message.

Any ideas?

Noticed there is another similar defect open: https://issues.apache.org/jira/browse/KAFKA-3702

Not sure if this is the same as that issue. .

Also another post from grokbase: [http://grokbase.com/t/kafka/users/1653bm0a02/warn-failed-to-send-ssl-close-message]

 
{code:java}
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(getConsumerConfiguration());

try{
   Map<String, List<PartitionInfo>> topics = consumer.listTopics();
   return new ArrayList<String>(topics.keySet());
}
finally{
    if (consumer != null){
          consumer.close();
    }
}
{code}
I am getting the warning from *consumer.close*.

The configuration of the consumer:
 * sasl.mechanism = PLAIN
 * security.protocol = SASL_SSL
 * group.id = consumer1
 * ssl.enabled.protocol = TLSv1.2
 * ssl.endpoint.identification.algorithm = HTTPS
 * ssl.protocol = TLSv1.2
 * sasl.jaas.config = org.apache.kafka.common.security.plain.PlainLoginModule required username="USERNAME"
password="PASSWORD";

{quote}[WARN ] 2018-01-25 20:12:23.204 [ClusterChannelMonitorTaskThread] org.apache.kafka.common.network.SslTransportLayer
{} - Failed to send SSL Close message java.io.IOException: Unexpected status returned by SSLEngine.wrap,
expected CLOSED, received OK. Will not send close message to peer. at org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:158)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.utils.Utils.closeAll(Utils.java:663)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:59)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.Selector.doClose(Selector.java:582)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.Selector.close(Selector.java:573)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.Selector.close(Selector.java:539)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.Selector.close(Selector.java:250)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.NetworkClient.close(NetworkClient.java:505)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.close(ConsumerNetworkClient.java:439)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.ClientUtils.closeQuietly(ClientUtils.java:71)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1613)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1573)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1549)
[kafka-clients-0.11.0.0.jar:?] at 
{quote}

  was:
I have a thread which once in a while is going to list the topics on the Message Hub. But
once in a while, I am getting a :Failed to send SSL Close message.

Any ideas?

Noticed there is another similar defect open: https://issues.apache.org/jira/browse/KAFKA-3702

Not sure if they are the same.
{code:java}
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(getConsumerConfiguration());

try{
   Map<String, List<PartitionInfo>> topics = consumer.listTopics();
   return new ArrayList<String>(topics.keySet());
}
finally{
    if (consumer != null){
          consumer.close();
    }
}
{code}
I am getting the warning from *consumer.close*.

The configuration of the consumer:
 * sasl.mechanism = PLAIN
 * security.protocol = SASL_SSL
 * group.id = consumer1
 * ssl.enabled.protocol = TLSv1.2
 * ssl.endpoint.identification.algorithm = HTTPS
 * ssl.protocol = TLSv1.2
 * sasl.jaas.config = org.apache.kafka.common.security.plain.PlainLoginModule required username="USERNAME"
password="PASSWORD";

{quote}[WARN ] 2018-01-25 20:12:23.204 [ClusterChannelMonitorTaskThread] org.apache.kafka.common.network.SslTransportLayer
{} - Failed to send SSL Close message java.io.IOException: Unexpected status returned by SSLEngine.wrap,
expected CLOSED, received OK. Will not send close message to peer. at org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:158)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.utils.Utils.closeAll(Utils.java:663)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:59)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.Selector.doClose(Selector.java:582)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.Selector.close(Selector.java:573)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.Selector.close(Selector.java:539)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.Selector.close(Selector.java:250)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.NetworkClient.close(NetworkClient.java:505)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.close(ConsumerNetworkClient.java:439)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.ClientUtils.closeQuietly(ClientUtils.java:71)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1613)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1573)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1549)
[kafka-clients-0.11.0.0.jar:?] at 
{quote}


> WARN: Fail to send SSL Close message
> ------------------------------------
>
>                 Key: KAFKA-6510
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6510
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 0.11.0.0
>            Reporter: John Chu
>            Priority: Major
>
> I have a thread which once in a while is going to list the topics on the Message Hub.
But once in a while, I am getting a :Failed to send SSL Close message.
> Any ideas?
> Noticed there is another similar defect open: https://issues.apache.org/jira/browse/KAFKA-3702
> Not sure if this is the same as that issue. .
> Also another post from grokbase: [http://grokbase.com/t/kafka/users/1653bm0a02/warn-failed-to-send-ssl-close-message]
>  
> {code:java}
> KafkaConsumer<String, String> consumer = new KafkaConsumer<>(getConsumerConfiguration());
> try{
>    Map<String, List<PartitionInfo>> topics = consumer.listTopics();
>    return new ArrayList<String>(topics.keySet());
> }
> finally{
>     if (consumer != null){
>           consumer.close();
>     }
> }
> {code}
> I am getting the warning from *consumer.close*.
> The configuration of the consumer:
>  * sasl.mechanism = PLAIN
>  * security.protocol = SASL_SSL
>  * group.id = consumer1
>  * ssl.enabled.protocol = TLSv1.2
>  * ssl.endpoint.identification.algorithm = HTTPS
>  * ssl.protocol = TLSv1.2
>  * sasl.jaas.config = org.apache.kafka.common.security.plain.PlainLoginModule required
username="USERNAME" password="PASSWORD";
> {quote}[WARN ] 2018-01-25 20:12:23.204 [ClusterChannelMonitorTaskThread] org.apache.kafka.common.network.SslTransportLayer
{} - Failed to send SSL Close message java.io.IOException: Unexpected status returned by SSLEngine.wrap,
expected CLOSED, received OK. Will not send close message to peer. at org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:158)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.utils.Utils.closeAll(Utils.java:663)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:59)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.Selector.doClose(Selector.java:582)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.Selector.close(Selector.java:573)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.Selector.close(Selector.java:539)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.common.network.Selector.close(Selector.java:250)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.NetworkClient.close(NetworkClient.java:505)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.close(ConsumerNetworkClient.java:439)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.ClientUtils.closeQuietly(ClientUtils.java:71)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1613)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1573)
[kafka-clients-0.11.0.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1549)
[kafka-clients-0.11.0.0.jar:?] at 
> {quote}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message