Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Unexpected error when try to delete a lot of topics #636

Open
Chillax-0v0 opened this issue Jan 4, 2024 · 0 comments
Open

Unexpected error when try to delete a lot of topics #636

Chillax-0v0 opened this issue Jan 4, 2024 · 0 comments
Labels
bug Something isn't working Stale

Comments

@Chillax-0v0
Copy link
Contributor

When I try to delete 512 topics (7 partitions in each), I got:
server.log

[2024-01-04 06:43:30,093] ERROR [KafkaApi-1] Unexpected error handling request RequestHeader(apiKey=DELETE_TOPICS, apiVersion=6, clientId=adminclient-1, correlationId=4, headerVersion=2) -- DeleteTopicsRequestData(topics=[...], topicNames=[], timeoutMs=30000) with context RequestContext(header=RequestHeader(apiKey=DELETE_TOPICS, apiVersion=6, clientId=adminclient-1, correlationId=4, headerVersion=2), connectionId='10.0.0.201:9092-10.0.0.119:48468-352', clientAddress=/10.0.0.119, principal=User:ANONYMOUS, listenerName=ListenerName(PLAINTEXT), securityProtocol=PLAINTEXT, clientInformation=ClientInformation(softwareName=apache-kafka-java, softwareVersion=3.4.0), fromPrivilegedListener=true, principalSerde=Optional[org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder@4c294eb3]) (kafka.server.KafkaApis)
java.util.NoSuchElementException: None.get
	at scala.None$.get(Option.scala:627)
	at scala.None$.get(Option.scala:626)
	at kafka.server.KafkaApis.$anonfun$getPartitionEpochSnapshotMap$4(KafkaApis.scala:170)
	at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:190)
	at kafka.server.KafkaApis.$anonfun$getPartitionEpochSnapshotMap$2(KafkaApis.scala:169)
	at kafka.server.KafkaApis.$anonfun$getPartitionEpochSnapshotMap$2$adapted(KafkaApis.scala:167)
	at scala.Option.foreach(Option.scala:437)
	at kafka.server.KafkaApis.$anonfun$getPartitionEpochSnapshotMap$1(KafkaApis.scala:167)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	at kafka.server.KafkaApis.getPartitionEpochSnapshotMap(KafkaApis.scala:161)
	at kafka.server.KafkaApis.handle(KafkaApis.scala:189)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:77)
	at java.base/java.lang.Thread.run(Thread.java:840)

There's also a memory leak after a while:
server.log

[2024-01-04 06:45:19,432] ERROR LEAK: ByteBuf.release() was not called before it's garbage-collected. See https://netty.io/wiki/reference-counted-objects.html for more information.
Recent access records:
Created at:
        io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:403)
        io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:188)
        io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:179)
        com.automq.stream.s3.DirectByteBufAlloc.byteBuffer(DirectByteBufAlloc.java:50)
        com.automq.stream.s3.DirectByteBufAlloc.byteBuffer(DirectByteBufAlloc.java:42)
        kafka.log.streamaspect.ElasticLogFileRecords$PooledMemoryRecords.<init>(ElasticLogFileRecords.java:326)
        kafka.log.streamaspect.ElasticLogFileRecords$PooledMemoryRecords.of(ElasticLogFileRecords.java:342)
        kafka.log.streamaspect.ElasticLogFileRecords.lambda$readAll0$1(ElasticLogFileRecords.java:140)
        java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:646)
        java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
        java.base/java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:614)
        java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:653)
        java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
        java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
        java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
        java.base/java.lang.Thread.run(Thread.java:840) (io.netty.util.ResourceLeakDetector)
@Chillax-0v0 Chillax-0v0 added the bug Something isn't working label Jan 4, 2024
daniel-y pushed a commit that referenced this issue Mar 14, 2024
@github-actions github-actions bot added the Stale label Apr 4, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working Stale
Projects
None yet
Development

No branches or pull requests

1 participant