[jira] [Commented] (KAFKA-16510) java.lang.OutOfMemoryError in kafka-metadata-quorum.sh
[ https://issues.apache.org/jira/browse/KAFKA-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836529#comment-17836529 ] Luke Chen commented on KAFKA-16510: --- OK, I see. If it's the issue of incorrectly SASL_SSL setting, then I think it's a known issue. Thanks for the reply. > java.lang.OutOfMemoryError in kafka-metadata-quorum.sh > -- > > Key: KAFKA-16510 > URL: https://issues.apache.org/jira/browse/KAFKA-16510 > Project: Kafka > Issue Type: Bug > Components: tools >Affects Versions: 3.7.0 >Reporter: Hiro >Priority: Major > > kafka-metadata-quorum is not available in SASL_PLAIN. > I got this error, I only use SASL_PLAIN. not use SSL. > I found a person with a similar situation, but he is using mTLS. > https://issues.apache.org/jira/browse/KAFKA-16006 > {code:java} > sh-4.2$ /opt/kafka/bin/kafka-metadata-quorum.sh --bootstrap-server ip>:9093 --command-config controller-admin.properties describe --replication > [2024-04-11 04:12:54,128] ERROR Uncaught exception in thread > ‘kafka-admin-client-thread | adminclient-1': > (org.apache.kafka.common.utils.KafkaThread) > java.lang.OutOfMemoryError: Java heap space > at java.base/java.nio.HeapByteBuffer.(HeapByteBuffer.java:64) > at java.base/java.nio.ByteBuffer.allocate(ByteBuffer.java:363) > at > org.apache.kafka.common.memory.MemoryPool$1.tryAllocate(MemoryPool.java:30) > at > org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:102) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveResponseOrToken(SaslClientAuthenticator.java:476) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveKafkaResponse(SaslClientAuthenticator.java:573) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.authenticate(SaslClientAuthenticator.java:251) > at > org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:181) > at > org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) > at org.apache.kafka.common.network.Selector.poll(Selector.java:481) > at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:585) > at > org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1504) > at > org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1435) > at java.base/java.lang.Thread.run(Thread.java:840) > org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has > exited. Call: describeMetadataQuorum > java.util.concurrent.ExecutionException: > org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has > exited. Call: describeMetadataQuorum > at > java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) > at > java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) > at > org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165) > at > org.apache.kafka.tools.MetadataQuorumCommand.handleDescribeReplication(MetadataQuorumCommand.java:158) > at > org.apache.kafka.tools.MetadataQuorumCommand.execute(MetadataQuorumCommand.java:106) > at > org.apache.kafka.tools.MetadataQuorumCommand.mainNoExit(MetadataQuorumCommand.java:62) > at > org.apache.kafka.tools.MetadataQuorumCommand.main(MetadataQuorumCommand.java:57) > Caused by: org.apache.kafka.common.errors.TimeoutException: The AdminClient > thread has exited. Call: describeMetadataQuorum {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-16510) java.lang.OutOfMemoryError in kafka-metadata-quorum.sh
[ https://issues.apache.org/jira/browse/KAFKA-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836517#comment-17836517 ] Hiro commented on KAFKA-16510: -- [~showuon] No, the problem occurred with all scripts. When I tried it yesterday, I thought the problem was resolved by changing the heap size, but now the same problem occurs even if I set KAFKA_HEAP_OPTS. Currently, this problem can be reproduced by incorrectly SASL_SSL setting or not setting around SASL_SSL configs in --command-config. Thanks. {code} sh-4.2$ /opt/kafka/bin/kafka-topics.sh --bootstrap-server :9093 --list Error while executing topic command : The AdminClient thread has exited. Call: listTopics [2024-04-12 09:00:55,990] ERROR org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has exited. Call: listTopics (org.apache.kafka.tools.TopicCommand) [2024-04-12 09:00:55,997] ERROR Uncaught exception in thread 'kafka-admin-client-thread | adminclient-1': (org.apache.kafka.common.utils.KafkaThread) java.lang.OutOfMemoryError: Java heap space at java.base/java.nio.HeapByteBuffer.(HeapByteBuffer.java:64) at java.base/java.nio.ByteBuffer.allocate(ByteBuffer.java:363) at org.apache.kafka.common.memory.MemoryPool$1.tryAllocate(MemoryPool.java:30) at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:102) at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:452) at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:402) at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:674) at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:576) at org.apache.kafka.common.network.Selector.poll(Selector.java:481) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:585) at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1504) at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1435) at java.base/java.lang.Thread.run(Thread.java:840) {code} > java.lang.OutOfMemoryError in kafka-metadata-quorum.sh > -- > > Key: KAFKA-16510 > URL: https://issues.apache.org/jira/browse/KAFKA-16510 > Project: Kafka > Issue Type: Bug > Components: tools >Affects Versions: 3.7.0 >Reporter: Hiro >Priority: Major > > kafka-metadata-quorum is not available in SASL_PLAIN. > I got this error, I only use SASL_PLAIN. not use SSL. > I found a person with a similar situation, but he is using mTLS. > https://issues.apache.org/jira/browse/KAFKA-16006 > {code:java} > sh-4.2$ /opt/kafka/bin/kafka-metadata-quorum.sh --bootstrap-server ip>:9093 --command-config controller-admin.properties describe --replication > [2024-04-11 04:12:54,128] ERROR Uncaught exception in thread > ‘kafka-admin-client-thread | adminclient-1': > (org.apache.kafka.common.utils.KafkaThread) > java.lang.OutOfMemoryError: Java heap space > at java.base/java.nio.HeapByteBuffer.(HeapByteBuffer.java:64) > at java.base/java.nio.ByteBuffer.allocate(ByteBuffer.java:363) > at > org.apache.kafka.common.memory.MemoryPool$1.tryAllocate(MemoryPool.java:30) > at > org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:102) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveResponseOrToken(SaslClientAuthenticator.java:476) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveKafkaResponse(SaslClientAuthenticator.java:573) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.authenticate(SaslClientAuthenticator.java:251) > at > org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:181) > at > org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) > at org.apache.kafka.common.network.Selector.poll(Selector.java:481) > at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:585) > at > org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1504) > at > org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1435) > at java.base/java.lang.Thread.run(Thread.java:840) > org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has > exited. Call: describeMetadataQuorum > java.util.concurrent.ExecutionException: > org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has > exited. Call: describeMetadataQuorum > at >
[jira] [Commented] (KAFKA-16510) java.lang.OutOfMemoryError in kafka-metadata-quorum.sh
[ https://issues.apache.org/jira/browse/KAFKA-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836501#comment-17836501 ] Luke Chen commented on KAFKA-16510: --- [~hiroa] , I'd like to confirm that only `kafka-metadata-quorum.sh` script causes OOM issue, not other scripts, like kafka-topics.sh, kafka-configs.sh. Is that right? > java.lang.OutOfMemoryError in kafka-metadata-quorum.sh > -- > > Key: KAFKA-16510 > URL: https://issues.apache.org/jira/browse/KAFKA-16510 > Project: Kafka > Issue Type: Bug > Components: tools >Affects Versions: 3.4.1 >Reporter: Hiro >Priority: Major > > kafka-metadata-quorum is not available in SASL_PLAIN. > I got this error, I only use SASL_PLAIN. not use SSL. > I found a person with a similar situation, but he is using mTLS. > https://issues.apache.org/jira/browse/KAFKA-16006 > {code:java} > sh-4.2$ /opt/kafka/bin/kafka-metadata-quorum.sh --bootstrap-server ip>:9093 --command-config controller-admin.properties describe --replication > [2024-04-11 04:12:54,128] ERROR Uncaught exception in thread > ‘kafka-admin-client-thread | adminclient-1': > (org.apache.kafka.common.utils.KafkaThread) > java.lang.OutOfMemoryError: Java heap space > at java.base/java.nio.HeapByteBuffer.(HeapByteBuffer.java:64) > at java.base/java.nio.ByteBuffer.allocate(ByteBuffer.java:363) > at > org.apache.kafka.common.memory.MemoryPool$1.tryAllocate(MemoryPool.java:30) > at > org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:102) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveResponseOrToken(SaslClientAuthenticator.java:476) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveKafkaResponse(SaslClientAuthenticator.java:573) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.authenticate(SaslClientAuthenticator.java:251) > at > org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:181) > at > org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) > at org.apache.kafka.common.network.Selector.poll(Selector.java:481) > at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:585) > at > org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1504) > at > org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1435) > at java.base/java.lang.Thread.run(Thread.java:840) > org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has > exited. Call: describeMetadataQuorum > java.util.concurrent.ExecutionException: > org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has > exited. Call: describeMetadataQuorum > at > java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) > at > java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) > at > org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165) > at > org.apache.kafka.tools.MetadataQuorumCommand.handleDescribeReplication(MetadataQuorumCommand.java:158) > at > org.apache.kafka.tools.MetadataQuorumCommand.execute(MetadataQuorumCommand.java:106) > at > org.apache.kafka.tools.MetadataQuorumCommand.mainNoExit(MetadataQuorumCommand.java:62) > at > org.apache.kafka.tools.MetadataQuorumCommand.main(MetadataQuorumCommand.java:57) > Caused by: org.apache.kafka.common.errors.TimeoutException: The AdminClient > thread has exited. Call: describeMetadataQuorum {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-16510) java.lang.OutOfMemoryError in kafka-metadata-quorum.sh
[ https://issues.apache.org/jira/browse/KAFKA-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836431#comment-17836431 ] Hiro commented on KAFKA-16510: -- [~leizhiyuan] Thank you your support ! this problem was resolved :) > java.lang.OutOfMemoryError in kafka-metadata-quorum.sh > -- > > Key: KAFKA-16510 > URL: https://issues.apache.org/jira/browse/KAFKA-16510 > Project: Kafka > Issue Type: Bug > Components: tools >Affects Versions: 3.4.1 >Reporter: Hiro >Priority: Major > > kafka-metadata-quorum is not available in SASL_PLAIN. > I got this error, I only use SASL_PLAIN. not use SSL. > I found a person with a similar situation, but he is using mTLS. > https://issues.apache.org/jira/browse/KAFKA-16006 > {code:java} > sh-4.2$ /opt/kafka/bin/kafka-metadata-quorum.sh --bootstrap-server ip>:9093 --command-config controller-admin.properties describe --replication > [2024-04-11 04:12:54,128] ERROR Uncaught exception in thread > ‘kafka-admin-client-thread | adminclient-1': > (org.apache.kafka.common.utils.KafkaThread) > java.lang.OutOfMemoryError: Java heap space > at java.base/java.nio.HeapByteBuffer.(HeapByteBuffer.java:64) > at java.base/java.nio.ByteBuffer.allocate(ByteBuffer.java:363) > at > org.apache.kafka.common.memory.MemoryPool$1.tryAllocate(MemoryPool.java:30) > at > org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:102) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveResponseOrToken(SaslClientAuthenticator.java:476) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveKafkaResponse(SaslClientAuthenticator.java:573) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.authenticate(SaslClientAuthenticator.java:251) > at > org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:181) > at > org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) > at org.apache.kafka.common.network.Selector.poll(Selector.java:481) > at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:585) > at > org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1504) > at > org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1435) > at java.base/java.lang.Thread.run(Thread.java:840) > org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has > exited. Call: describeMetadataQuorum > java.util.concurrent.ExecutionException: > org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has > exited. Call: describeMetadataQuorum > at > java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) > at > java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) > at > org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165) > at > org.apache.kafka.tools.MetadataQuorumCommand.handleDescribeReplication(MetadataQuorumCommand.java:158) > at > org.apache.kafka.tools.MetadataQuorumCommand.execute(MetadataQuorumCommand.java:106) > at > org.apache.kafka.tools.MetadataQuorumCommand.mainNoExit(MetadataQuorumCommand.java:62) > at > org.apache.kafka.tools.MetadataQuorumCommand.main(MetadataQuorumCommand.java:57) > Caused by: org.apache.kafka.common.errors.TimeoutException: The AdminClient > thread has exited. Call: describeMetadataQuorum {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (KAFKA-16510) java.lang.OutOfMemoryError in kafka-metadata-quorum.sh
[ https://issues.apache.org/jira/browse/KAFKA-16510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836026#comment-17836026 ] Zhiyuan Lei commented on KAFKA-16510: - run in local, it should be that the default heap size of your local JVM is too small. The default KAFKA_HEAP_OPTS is 256M. You can try exporting KAFKA_HEAP_OPTS=-Xmx2048M before starting it again. ``` # Memory options if [ -z "$KAFKA_HEAP_OPTS" ]; then KAFKA_HEAP_OPTS="-Xmx256M" fi ``` > java.lang.OutOfMemoryError in kafka-metadata-quorum.sh > -- > > Key: KAFKA-16510 > URL: https://issues.apache.org/jira/browse/KAFKA-16510 > Project: Kafka > Issue Type: Bug > Components: tools >Affects Versions: 3.4.1 >Reporter: Hiro >Priority: Major > > kafka-metadata-quorum is not available in SASL_PLAIN. > I got this error, I only use SASL_PLAIN. not use SSL. > I found a person with a similar situation, but he is using mTLS. > https://issues.apache.org/jira/browse/KAFKA-16006 > {code:java} > sh-4.2$ /opt/kafka/bin/kafka-metadata-quorum.sh --bootstrap-server ip>:9093 --command-config controller-admin.properties describe --replication > [2024-04-11 04:12:54,128] ERROR Uncaught exception in thread > ‘kafka-admin-client-thread | adminclient-1': > (org.apache.kafka.common.utils.KafkaThread) > java.lang.OutOfMemoryError: Java heap space > at java.base/java.nio.HeapByteBuffer.(HeapByteBuffer.java:64) > at java.base/java.nio.ByteBuffer.allocate(ByteBuffer.java:363) > at > org.apache.kafka.common.memory.MemoryPool$1.tryAllocate(MemoryPool.java:30) > at > org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:102) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveResponseOrToken(SaslClientAuthenticator.java:476) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.receiveKafkaResponse(SaslClientAuthenticator.java:573) > at > org.apache.kafka.common.security.authenticator.SaslClientAuthenticator.authenticate(SaslClientAuthenticator.java:251) > at > org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:181) > at > org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) > at org.apache.kafka.common.network.Selector.poll(Selector.java:481) > at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:585) > at > org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1504) > at > org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1435) > at java.base/java.lang.Thread.run(Thread.java:840) > org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has > exited. Call: describeMetadataQuorum > java.util.concurrent.ExecutionException: > org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has > exited. Call: describeMetadataQuorum > at > java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) > at > java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) > at > org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165) > at > org.apache.kafka.tools.MetadataQuorumCommand.handleDescribeReplication(MetadataQuorumCommand.java:158) > at > org.apache.kafka.tools.MetadataQuorumCommand.execute(MetadataQuorumCommand.java:106) > at > org.apache.kafka.tools.MetadataQuorumCommand.mainNoExit(MetadataQuorumCommand.java:62) > at > org.apache.kafka.tools.MetadataQuorumCommand.main(MetadataQuorumCommand.java:57) > Caused by: org.apache.kafka.common.errors.TimeoutException: The AdminClient > thread has exited. Call: describeMetadataQuorum {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)