-
Bug
-
Resolution: Done
-
Undefined
-
3.0.1.GA, 2.9.3.GA
-
None
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