[jira] [Created] (KAFKA-9037) Java Out Of Memory(OOM) error encountered while deleting Kafka records using SASL designated port.

["Akshath Karanam (Jira)" <ji...@apache.org>]

Akshath Karanam created KAFKA-9037:
--------------------------------------

             Summary: Java Out Of Memory(OOM) error encountered while deleting Kafka records using SASL designated port.
                 Key: KAFKA-9037
                 URL: https://issues.apache.org/jira/browse/KAFKA-9037
             Project: Kafka
          Issue Type: Bug
            Reporter: Akshath Karanam


Hello,

 

We are using a Confluent Kafka setup with brokers, workers, and zookeepers. The brokers have been configured to run SASL mechanism on port 9094. Plaintext mode has not been configured on default port on 9092. 

 

While deleting the kafka topics records on the brokers using the SASL port, it has been seen that the broker throws a *_java.lang.OutOfMemoryError: Java heap space_* error. This  is how we are invoking the topics deletion command:

*Command:*

-------------
>> _/bin/kafka-delete-records --bootstrap-server localhost:9094 --offset-json-file /file.json_

 

 

*Error:*

-------------

java.lang.OutOfMemoryError: Java heap spacejava.lang.OutOfMemoryError: Java heap space at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57) at java.nio.ByteBuffer.allocate(ByteBuffer.java:335) at org.apache.kafka.common.memory.MemoryPool$1.tryAllocate(MemoryPool.java:30) at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:112) at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:390) at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:351) at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:609) at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:541) at org.apache.kafka.common.network.Selector.poll(Selector.java:467) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:535) at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1125) at java.lang.Thread.run(Thread.java:748)

 

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)