Anshul Khandelwal
Anshul Khandelwal

Reputation: 108

Class software.amazon.msk.auth.iam.IAMClientCallbackHandler could not be found

Below is our pom file, I tried several ways, I opened the container undet BOOT-INF I find the required jar files as well, but when ever on EKS I tried to produce event it fails with below error: java.util.concurrent.CompletionException: org.apache.kafka.common.config.ConfigException: Invalid value software.amazon.msk.auth.iam.IAMClientCallbackHandler for configuration sasl.client.callback.handler.class: Class software.amazon.msk.auth.iam.IAMClientCallbackHandler could not be found. at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(Unknown Source) at java.base/java.util.concurrent.CompletableFuture.completeThrowable(Unknown Source) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(Unknown Source) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.exec(Unknown Source) at java.base/java.util.concurrent.ForkJoinTask.doExec(Unknown Source) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source) at java.base/java.util.concurrent.ForkJoinPool.scan(Unknown Source) at java.base/java.util.concurrent.ForkJoinPool.runWorker(Unknown Source) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source) Caused by: org.apache.kafka.common.config.ConfigException: Invalid value software.amazon.msk.auth.iam.IAMClientCallbackHandler for configuration sasl.client.callback.handler.class: Class software.amazon.msk.auth.iam.IAMClientCallbackHandler could not be found. at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:747) at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:493) at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:486) at org.apache.kafka.common.config.AbstractConfig.(AbstractConfig.java:114) at org.apache.kafka.common.config.AbstractConfig.(AbstractConfig.java:134) at org.apache.kafka.clients.producer.ProducerConfig.(ProducerConfig.java:620) at org.apache.kafka.clients.producer.KafkaProducer.(KafkaProducer.java:294) at org.springframework.kafka.core.DefaultKafkaProducerFactory.createRawProducer(DefaultKafkaProducerFactory.java:944) at org.springframework.kafka.core.DefaultKafkaProducerFactory.createKafkaProducer(DefaultKafkaProducerFactory.java:826) at org.springframework.kafka.core.DefaultKafkaProducerFactory.doCreateProducer(DefaultKafkaProducerFactory.java:793) at org.springframework.kafka.core.DefaultKafkaProducerFactory.createProducer(DefaultKafkaProducerFactory.java:768) at org.springframework.kafka.core.DefaultKafkaProducerFactory.createProducer(DefaultKafkaProducerFactory.java:762) at org.springframework.kafka.core.KafkaTemplate.getTheProducer(KafkaTemplate.java:976) at org.springframework.kafka.core.KafkaTemplate.doSend(KafkaTemplate.java:828) at org.springframework.kafka.core.KafkaTemplate.observeSend(KafkaTemplate.java:805) at org.springframework.kafka.core.KafkaTemplate.send(KafkaTemplate.java:621) at com.fico.kafka.publisher.KafkaPublisher.publishMessageForActivityLog(KafkaPublisher.java:32) at com.fico.kafka.service.CreateKafkaEventService.createKafkaEventActivityLog(CreateKafkaEventService.java:58) at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(Unknown Source) at java.base/java.lang.reflect.Method.invoke(Unknown Source) at org.springframework.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:281) at org.springframework.cloud.context.scope.GenericScope$LockedScopedProxyFactoryBean.invoke(GenericScope.java:482) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:184) at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:727) at com.fico.kafka.service.CreateKafkaEventService$$SpringCGLIB$$0.createKafkaEventActivityLog() at com.fico.service.login.LoginService.createSuccessActivityLog(LoginService.java:264) at com.fico.service.login.LoginService.lambda$executeParallelOperations$5(LoginService.java:186) ... 7 common frames omitted

This is our pom file:

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <java.version>21</java.version>
    <maven.compiler.source>21</maven.compiler.source>
    <maven.compiler.target>21</maven.compiler.target>
    <spring-cloud.version>2024.0.0</spring-cloud.version>
    <modelmapper.version>3.2.2</modelmapper.version>
    <hibernate-core.version>6.6.0.Final</hibernate-core.version>
    <aws.sdk.version>2.27.15</aws.sdk.version>
    <spring-vault-dependencies.version>3.0.0</spring-vault-dependencies.version>
    <springdoc.version>2.6.0</springdoc.version>
    <logback.version>1.5.15</logback.version>
    <lombok.version>1.18.36</lombok.version>
</properties>

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>3.4.1</version>
</parent>
<dependencies>
    <dependency>
        <groupId>com.fico.ngce.common.response</groupId>
        <artifactId>common-req-resp</artifactId>
        <version>1.0.1.initial</version>
    </dependency>
    <dependency>
        <groupId>org.modelmapper</groupId>
        <artifactId>modelmapper</artifactId>
        <version>${modelmapper.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
        <scope>runtime</scope>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <version>${lombok.version}</version>
        <scope>provided</scope>
    </dependency>
    <dependency>
        <groupId>org.springframework.kafka</groupId>
        <artifactId>spring-kafka</artifactId>
        <exclusions>
            <exclusion>
                <groupId>org.apache.kafka</groupId>
                <artifactId>kafka-clients</artifactId>
            </exclusion>
            <exclusion>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-stream-kafka</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-bus-kafka</artifactId>
        <exclusions>
            <exclusion>
                <groupId>org.apache.kafka</groupId>
                <artifactId>kafka-clients</artifactId>
            </exclusion>
            <exclusion>
                <groupId>software.amazon.msk</groupId>
                <artifactId>aws-msk-iam-auth</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-clients</artifactId>
        <version>3.7.1</version> 
    </dependency>

Upvotes: 0

Views: 37

Answers (0)

Related Questions