Не удалось отправить сообщение о закрытии SSL

У меня есть ветка, которая время от времени будет перечислять темы в Message Hub. Но время от времени я получаю сообщение: Не удалось отправить сообщение SSL Close.

Любые идеи?

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();**
    }
}

Я получаю предупреждение от consumer.close.

Конфигурация потребителя:

  • sasl.mechanism = ОБЫЧНАЯ
  • 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 требуется username = "USERNAME" password = "PASSWORD";

[ПРЕДУПРЕЖДЕНИЕ] 2018-01-25 20: 12: 23.204 [ClusterChannelMonitorTaskThread] org.apache.kafka.common.network.SslTransportLayer {} - не удалось отправить сообщение закрытия SSL java.io.IOException: SSLEngine.wrap вернул непредвиденный статус, Ожидается ЗАКРЫТО, получено ОК. Не будет отправлять сообщение о закрытии одноранговому узлу. на org.apache.kafka.common.network.SslTransportLayer.close (SslTransportLayer.java:158) [kafka-clients-0.11.0.0.jar :?] на org.apache.kafka.common.utils.Utils.closeAll (Utils .java: 663) [kafka-clients-0.11.0.0.jar :?] в org.apache.kafka.common.network.KafkaChannel.close (KafkaChannel.java:59) [kafka-clients-0.11.0.0.jar: ?] на org.apache.kafka.common.network.Selector.doClose (Selector.java:582) [kafka-clients-0.11.0.0.jar :?] на org.apache.kafka.common.network.Selector.close (Selector.java:573) [kafka-clients-0.11.0.0.jar :?] в org.apache.kafka.common.network.Selector.close (Selector.java:539) [kafka-clients-0.11.0.0. jar :?] в org.apache.kafka.common.network.Selector.close (Selector.java:250) [kafka-clients-0.11.0.0.jar :?] в org.apache.kafka.clients.NetworkClient.close (NetworkClient.java:505) [kafka-clients-0.11.0.0.jar :?] в org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.close (ConsumerNetworkClient.java:439) [kafka-c lients-0.11.0.0.jar :?] в org.apache.kafka.clients.ClientUtils.closeQuietly (ClientUtils.java:71) [kafka-clients-0.11.0.0.jar :?] в org.apache.kafka.clients .consumer.KafkaConsumer.close (KafkaConsumer.java:1613) [kafka-clients-0.11.0.0.jar :?] в org.apache.kafka.clients.consumer.KafkaConsumer.close (KafkaConsumer.java:1573) [kafka- clients-0.11.0.0.jar :?] в org.apache.kafka.clients.consumer.KafkaConsumer.close (KafkaConsumer.java:1549) [kafka-clients-0.11.0.0.jar :?] в com.ibm.saas .msg.kafka.KafkaMessageService.listChannelNames (KafkaMessageService.java:305) [saas-msg-kafka-TRUNK-SNAPSHOT.jar: TRUNK-SNAPSHOT]


java apache-kafka kafka-consumer-api sslengine message-hub
person John Chu    schedule 26.01.2018    source источник
comment
Похоже на ошибку в Кафке. SSLEngine - довольно сложная вещь для правильного вождения.   -  person user207421    schedule 31.01.2018
comment
Подал заявку на Kafka: issues.apache.org/jira/browse/KAFKA-6510 < / а>   -  person John Chu    schedule 01.02.2018

Ответы (2)


arrow_upward
0
arrow_downward

Удалите это исключение сегодня и с клиентом kafka 1.0.2: /

person Mike Emery    schedule 20.09.2018

arrow_upward
0
arrow_downward

Убедитесь, что вы установили правильное значение в / etc / hosts. Это очень важно. В моем случае я установил listeners=SASL_SSL://10.10.10.3:9093 в файле server.properties, поэтому мне нужно иметь 10.10.10.3 SzymekKafka в / etc / hosts, где SzymekKafka - мое имя хоста.

person Passarinho    schedule 21.09.2018