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

Console: Describing a group with active members through a user that doesn't have permissions to describe the topics throws NullPointerException

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Undefined Undefined
    • 3.1.0.GA
    • 3.0.1.GA, 2.9.3.GA
    • console
    • None
    • Moderate

      curl --user admin:password "http://localhost:8080/api/kafkas/ID/consumerGroups/GROUP_NAME?fields%5BconsumerGroups%5D=state,members,coordinator,offsets,simpleConsumerGroup" | jq
      {
        "errors": [
          {
            "title": "Unexpected error",
            "id": "6df7d021-681c-4c89-8671-e213997131fe",
            "status": "500",
            "code": "5001"
          }
        ]
      }
      
      

      Api Logs:

      2025-11-13 20:38:43,376 WARN  [com.git.str.con.api.err.ser.AbstractServerExceptionHandler] (vert.x-eventloop-thread-4) error=id=3f28c481-8340-4662-bd23-24ae6d83f044 title='Unexpected error' detail='null' source=null: java.lang.NullPointerException
      	at java.base/java.util.Objects.requireNonNull(Objects.java:233)
      	at com.github.streamshub.console.api.model.PartitionId.<init>(PartitionId.java:18)
      	at com.github.streamshub.console.api.model.MemberDescription.lambda$fromKafkaModel$0(MemberDescription.java:49)
      	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
      	at java.base/java.util.HashMap$KeySpliterator.forEachRemaining(HashMap.java:1715)
      	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
      	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
      	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:575)
      	at java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260)
      	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:616)
      	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:622)
      	at java.base/java.util.stream.ReferencePipeline.toList(ReferencePipeline.java:627)
      	at com.github.streamshub.console.api.model.MemberDescription.fromKafkaModel(MemberDescription.java:50)
      	at com.github.streamshub.console.api.model.ConsumerGroup.lambda$fromKafkaModel$0(ConsumerGroup.java:210)
      	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
      	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1708)
      	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
      	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
      	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:575)
      	at java.base/java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:260)
      	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:616)
      	at java.base/java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:622)
      	at java.base/java.util.stream.ReferencePipeline.toList(ReferencePipeline.java:627)
      	at com.github.streamshub.console.api.model.ConsumerGroup.fromKafkaModel(ConsumerGroup.java:211)
      	at com.github.streamshub.console.api.service.ConsumerGroupService.lambda$describeConsumerGroups$57(ConsumerGroupService.java:514)
      	at java.base/java.util.concurrent.CompletableFuture.biApply(CompletableFuture.java:1311)
      	at java.base/java.util.concurrent.CompletableFuture$BiApply.tryFire(CompletableFuture.java:1280)
      
      

      KafkaUser:

      spec:
        authentication:
          type: scram-sha-512
        authorization:
          acls:
            - host: '*'
              operations:
                - Read
                - Describe
                - Write
                - Create
              resource:
                name: my-topic
                patternType: literal
                type: topic
            - operations:
                - Read
                - Describe
                - DescribeConfigs
              resource:
                name: '*'
                patternType: literal
                type: group
            - operations:
                - Read
                - Describe
                - DescribeConfigs
              resource:
                type: cluster
          type: simple
      

              Unassigned Unassigned
              rhn-support-adongre Avinash Dongre
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated:
                Resolved: