-
-
Notifications
You must be signed in to change notification settings - Fork 222
Description
Issue submitter TODO list
- I've looked up my issue in FAQ
- I've searched for an already existing issues here
- I've tried running
main-labeled docker image and the issue still persists there - I'm running a supported version of the application which is listed here
Describe the bug (actual behavior)
We are trying to connect from kafka ui (v1.3.0) using helm chart 1.5.1(https://artifacthub.io/packages/helm/kafka-ui/kafka-ui) to connect to kafka cluster
configuration is correct username and password to connect to kafka cluster is correct, but still getting error, same is working fine with kafka ui (v1.2.0) using helm chart 1.5.0(https://artifacthub.io/packages/helm/kafka-ui/kafka-ui) to connect to kafka cluster.
we are getting error for connecting kafka ui (v1.3.0) using helm chart 1.5.1 to connect to kafka cluster
Failed to collect cluster yaml info
java.lang.IllegalStateException: Error while creating AdminClient for the cluster yaml
at io.kafbat.ui.service.AdminClientServiceImpl.lambda$createAdminClient$5(AdminClientServiceImpl.java:58)
at reactor.core.publisher.Mono.lambda$onErrorMap$29(Mono.java:3862)
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:94)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:241)
at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:315)
at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onError(MonoPeekTerminal.java:258)
at reactor.core.publisher.FluxMap$MapConditionalSubscriber.onError(FluxMap.java:265)
at reactor.core.publisher.Operators$MonoSubscriber.onError(Operators.java:1911)
at reactor.core.publisher.MonoCacheTime$CoordinatorSubscriber.signalCached(MonoCacheTime.java:340)
at reactor.core.publisher.MonoCacheTime$CoordinatorSubscriber.onError(MonoCacheTime.java:363)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:241)
at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:315)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:136)
at reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:297)
at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:478)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122)
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79)
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79)
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79)
at reactor.core.publisher.MonoPublishOn$PublishOnSubscriber.run(MonoPublishOn.java:181)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: java.lang.NullPointerException: null
at java.base/java.util.Objects.requireNonNull(Objects.java:233)
at java.base/java.util.Optional.of(Optional.java:113)
at io.kafbat.ui.service.ReactiveAdminClient$ConfigRelatedInfo.lambda$extract$2(ReactiveAdminClient.java:166)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:132)
... 15 common frames omitted
←[30m2025-08-07 06:30:18,234←[0;39m ←[39mDEBUG←[0;39m [←[34mparallel-1←[0;39m] ←[33mi.k.u.s.ClustersStatisticsScheduler←[0;39m: Metrics updated for cluster: yaml
Expected behavior
kafka ui (v1.3.0) using helm chart 1.5.1(https://artifacthub.io/packages/helm/kafka-ui/kafka-ui) should be connect to Kafka cluster
Your installation details
we are using the official Kafka UI Helm chart (v1.5.1)
our Kafka cluster uses SASL_PLAINTEXT with SCRAM-SHA-512
already have the correct username and password (possibly stored in a Kubernetes secret)
Steps to reproduce
1-> install kafka-ui helm chart chart (v1.5.1)](https://artifacthub.io/packages/helm/kafka-ui/kafka-ui)
2-> try to connect to kafka cluster.
Screenshots
Logs
No response
Additional context
No response