-
Couldn't load subscription status.
- Fork 41
Open
Description
What happened?
When set config rsm.config.upload.rate.limit.bytes.per.second=2147483647 to start kafka, the following error occurs
[2025-09-05 15:41:49,926] ERROR Exiting Kafka due to fatal exception during startup. (kafka.Kafka$)
java.lang.IllegalArgumentException: 2.147 token/nanosecond is not permitted refill rate, because highest supported rate is 1 token/nanosecond
at io.github.bucket4j.BucketExceptions.tooHighRefillRate(BucketExceptions.java:176)
at io.github.bucket4j.BandwidthBuilder$BandwidthBuilderImpl.setRefill(BandwidthBuilder.java:323)
at io.github.bucket4j.BandwidthBuilder$BandwidthBuilderImpl.refillGreedy(BandwidthBuilder.java:255)
at io.aiven.kafka.tieredstorage.transform.RateLimitedInputStream.lambda$rateLimitBucket$0(RateLimitedInputStream.java:52)
at io.github.bucket4j.local.LocalBucketBuilder.addLimit(LocalBucketBuilder.java:56)
at io.aiven.kafka.tieredstorage.transform.RateLimitedInputStream.rateLimitBucket(RateLimitedInputStream.java:49)
at io.aiven.kafka.tieredstorage.RemoteStorageManager.lambda$configure$1(RemoteStorageManager.java:181)
at java.base/java.util.OptionalInt.ifPresent(OptionalInt.java:165)
at io.aiven.kafka.tieredstorage.RemoteStorageManager.configure(RemoteStorageManager.java:180)
at org.apache.kafka.server.log.remote.storage.ClassLoaderAwareRemoteStorageManager.lambda$configure$0(ClassLoaderAwareRemoteStorageManager.java:48)
at org.apache.kafka.server.log.remote.storage.ClassLoaderAwareRemoteStorageManager.withClassLoader(ClassLoaderAwareRemoteStorageManager.java:65)
at org.apache.kafka.server.log.remote.storage.ClassLoaderAwareRemoteStorageManager.configure(ClassLoaderAwareRemoteStorageManager.java:47)
at kafka.log.remote.RemoteLogManager.configureRSM(RemoteLogManager.java:349)
at kafka.log.remote.RemoteLogManager.startup(RemoteLogManager.java:388)
at kafka.server.KafkaServer.$anonfun$startup$24(KafkaServer.scala:579)
at kafka.server.KafkaServer.$anonfun$startup$24$adapted(KafkaServer.scala:569)
at scala.Option.foreach(Option.scala:437)
at kafka.server.KafkaServer.startup(KafkaServer.scala:569)
at kafka.Kafka$.main(Kafka.scala:112)
at kafka.Kafka.main(Kafka.scala)
Metadata
Metadata
Assignees
Labels
No labels