- 
                Notifications
    
You must be signed in to change notification settings  - 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