Uploaded image for project: 'AMQ Streams'
  1. AMQ Streams
  2. ENTMQST-5197

Allow use of default user quota while User Operator is enabled

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Undefined Undefined
    • 2.6.0.GA
    • None
    • None
    • None
    • False
    • None
    • False
    • Hide

      Tested manually. 

      Show
      Tested manually. 

      Kafka allows to set a default quota for all users using the Kafka Admin API:
       bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter --add-config 'producer_byte_rate=1024,consumer_byte_rate=2048,request_percentage=200' --entity-type users --entity-default
       
      But it seems to conflict with the User Operator:

      2023-09-08 11:56:57 ERROR AbstractCache:149 - QuotasCache failed to update
      java.lang.NullPointerException: null
      at java.util.concurrent.ConcurrentHashMap.putVal(ConcurrentHashMap.java:1011) ~[?:?]
      at java.util.concurrent.ConcurrentHashMap.put(ConcurrentHashMap.java:1006) ~[?:?]
      at io.strimzi.operator.user.operator.cache.QuotasCache.loadCache(QuotasCache.java:56) ~[io.strimzi.user-operator-0.38.0-SNAPSHOT.jar:0.38.0-SNAPSHOT]
      at io.strimzi.operator.user.operator.cache.AbstractCache.updateCache(AbstractCache.java:146) ~[io.strimzi.user-operator-0.38.0-SNAPSHOT.jar:0.38.0-SNAPSHOT]
      at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
      at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) ~[?:?]
      at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
      at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
      at java.lang.Thread.run(Thread.java:833) ~[?:?]
      

       
      We should try to look if we can make it both work together - probably by ignoring the default quota in UO.

      Created by Strimzi#9096

              Unassigned Unassigned
              scholzj JAkub Scholz
              Henrich Zrncik Henrich Zrncik
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated:
                Resolved: