Bitnami Kafka VM and application.yml

[Atomciok]

Hi Ludovic,

I would like to test standalone AKHQ in combination with Bitnami Kafka VM
https://bitnami.com/stack/kafka/virtual-machine.
Could you please publish an application.yml as example for Bitnami Kafka configuration?
I am stuck on "Failed to create new KafkaAdminClient" problem

Thanks
Andre

[tchiotludo]

Please provide a full stacktrace please ?

[Atomciok]

It is working now with the minimal configuration in application.yml:
akhq:
connections:
localhost:
properties:
bootstrap.servers: "localhost:9092"
security.protocol: SASL_PLAINTEXT
sasl.mechanism: PLAIN
sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="user" password="password";

KafkaClient username and password is from /opt/bitnami/kafka/config/kafka_jaas.conf
Bitnami docs: https://docs.bitnami.com/general/infrastructure/kafka/

During tests I see an error in "Consumer Groups" menu "Internal Server Error: from Index = -25" when clicking on "»" in « 1 of 0 » menu. The same error using your docker container instead bitnami VM.

2022-01-05 10:33:19,246 INFO r-thread-2 org.akhq.log.access [Date: 2022-01-05T10:33:19.235602Z] [Duration: 10 ms] [Url: GET /api/localhost/group] [Status: 200] [Ip: /192.168.110.21] [User: -]
2022-01-05 10:33:23,002 ERROR r-thread-3 o.a.c.ErrorController fromIndex = -25
java.lang.IndexOutOfBoundsException: fromIndex = -25
at java.base/java.util.AbstractList.subListRangeCheck(AbstractList.java:505)
at java.base/java.util.ArrayList.subList(ArrayList.java:1138)
at org.akhq.utils.PagedList.of(PagedList.java:67)
at org.akhq.repositories.ConsumerGroupRepository.list(ConsumerGroupRepository.java:42)
at org.akhq.controllers.GroupController.list(GroupController.java:67)
at org.akhq.controllers.$GroupController$Definition$Exec.dispatch(Unknown Source)
at io.micronaut.context.AbstractExecutableMethodsDefinition$DispatchedExecutableMethod.invoke(AbstractExecutableMethodsDefinition.java:351)
at io.micronaut.context.DefaultBeanContext$4.invoke(DefaultBeanContext.java:583)
at io.micronaut.web.router.AbstractRouteMatch.execute(AbstractRouteMatch.java:303)
at io.micronaut.web.router.RouteMatch.execute(RouteMatch.java:111)
at io.micronaut.http.context.ServerRequestContext.with(ServerRequestContext.java:103)
at io.micronaut.http.server.RouteExecutor.lambda$executeRoute$14(RouteExecutor.java:656)
at reactor.core.publisher.FluxDeferContextual.subscribe(FluxDeferContextual.java:49)
at reactor.core.publisher.InternalFluxOperator.subscribe(InternalFluxOperator.java:62)
at reactor.core.publisher.FluxSubscribeOn$SubscribeOnSubscriber.run(FluxSubscribeOn.java:194)
at io.micronaut.reactive.reactor.instrument.ReactorInstrumentation.lambda$null$0(ReactorInstrumentation.java:62)
at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)
at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)
at io.micronaut.scheduling.instrument.InvocationInstrumenterWrappedCallable.call(InvocationInstrumenterWrappedCallable.java:53)
at io.micrometer.core.instrument.composite.CompositeTimer.recordCallable(CompositeTimer.java:68)
at io.micrometer.core.instrument.Timer.lambda$wrap$1(Timer.java:171)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
2022-01-05 10:33:23,004 WARN r-thread-2 org.akhq.log.access [Date: 2022-01-05T10:33:22.997164Z] [Duration: 6 ms] [Url: GET /api/localhost/group] [Status: 500] [Ip: /192.168.110.21] [User: -]

[tchiotludo]

#976 created for the bug report 😃