[KAFKA-5592] Connection with plain client to SSL-secured broker causes OOM

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 0.11.0.0
• Component/s: clients
• Environment: Linux x86_64 x86_64 x86_64 GNU/Linux
• Assignee: Unassigned
• Reporter: Marcin Łuczyński
• Created: 14/Jul/17 10:16
• Updated: 08/Sep/17 11:14
• Resolved: 08/Sep/17 11:14

Description

While testing connection with client app that does not have configured truststore with a Kafka broker secured by SSL, my JVM crashes with OutOfMemoryError. I saw it mixed with StackOverfowError. I attach dump files.

The stack trace to start with is here:

at java/nio/HeapByteBuffer. (HeapByteBuffer.java:57)
at java/nio/ByteBuffer.allocate(ByteBuffer.java:331)
at org/apache/kafka/common/network/NetworkReceive.readFromReadableChannel(NetworkReceive.java:93)
at org/apache/kafka/common/network/NetworkReceive.readFrom(NetworkReceive.java:71)
at org/apache/kafka/common/network/KafkaChannel.receive(KafkaChannel.java:169)
at org/apache/kafka/common/network/KafkaChannel.read(KafkaChannel.java:150)
at org/apache/kafka/common/network/Selector.pollSelectionKeys(Selector.java:355)
at org/apache/kafka/common/network/Selector.poll(Selector.java:303)
at org/apache/kafka/clients/NetworkClient.poll(NetworkClient.java:349)
at org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.poll(ConsumerNetworkClient.java:226)
at org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.poll(ConsumerNetworkClient.java:188)
at org/apache/kafka/clients/consumer/internals/AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:207)
at org/apache/kafka/clients/consumer/internals/AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:193)
at org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.poll(ConsumerCoordinator.java:279)
at org/apache/kafka/clients/consumer/KafkaConsumer.pollOnce(KafkaConsumer.java:1029)
at org/apache/kafka/clients/consumer/KafkaConsumer.poll(KafkaConsumer.java:995)
at com/ibm/is/cc/kafka/runtime/KafkaConsumerProcessor.process(KafkaConsumerProcessor.java:237)
at com/ibm/is/cc/kafka/runtime/KafkaProcessor.process(KafkaProcessor.java:173)
at com/ibm/is/cc/javastage/connector/CC_JavaAdapter.run(CC_JavaAdapter.java:443)

Issue Links

• is duplicated by: KAFKA-4493 Connections to Kafka brokers should be validated