Class Software.amazon.msk.auth.iam.iamclientcallbackhandler не может быть найден ⇐ JAVA

[Anonymous]

Ниже приведен наш файл POM, я попробовал несколько способов, я открыл контейнер Undet Boot-inf, я также нахожу необходимые файлы JAR, но когда когда-либо на EKS я пытался произвести событие, он не удастся с ошибкой ниже:
java.util.concurrent.complationException: org.apache.kafka.common.config.configexception: Invalid Value Software.amazon.msk.auth.iam.iamClientCallbackHandler для конфигурации sasl.client.callback.handler.class: class.amazon. .msk.auth.iam.iamClientCallbackHandler нельзя найти. Uppateablefuture.completethrowable (неизвестный источник)
at java.base /java.util.concurrent.completablefuture $ asyncrun.run (неизвестный источник)
at java.base /java.util.concurrent.completablefuture $ asyncrun. Exec (неизвестный источник)
at java.base /java.util.concurrent.forkjointask.doexec (неизвестный источник)
at java.base /java.util.concurrent.forkjoinpool $ )
at java.base /java.util.concurrent.forkjoinpool.scan (неизвестный источник)
at java.base /java.util.concurrent.forkjoinpool.runworker (неизвестный источник)
at java.base /java.util.concurrent.forkjoinworkerthread.run (неизвестный источник)
вызван: org.apache.kafka.common.config.configexception: неверная стоимость программного обеспечения. Конфигурация sasl.client.callback.handler.class: class software.amazon.msk.auth.iam.iamclientcallbackhandler нельзя найти. : 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. (Producterconfig.java:620)
at org.apache.kafka.clients.producer.kafkaproducer. (kafkaproducer.java:294). br />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.javafaumpr ядро Kafkatemplate.dosend (kafkatemplate.java:828)
at org.springframework.kafka.core.kafkatemplate.observesd Kafkatemplate.java:621) Ава: 58)
at java.base /jdk.internal.reflect.directmethodleaccessor.invoke (неизвестный источник)
at java.base /java.lang.reflect.method.invoke (неизвестный источник)
at org.springframework.util.reflectionutils.invokemethod (ReflectionUtils.java:281)
at org.springframework.cloud.context.scope.genericscope $ lockedscopedproxyfactorybean.invoke (genericscope.java:482)
at or org orgopekeake.invoke (genericscope.java:482) .springframework.aop.framework.reflectivemethodinvocation.procece (RefertiveMethodinvocation.java:184)
at org.springframework.aop.framework.cglibaopproxy $ dynamicAdvisedIntertor .kafka.service.createkafkaeventservice $$ springcglib $$ 0.createkafkaeventactivitylog ()
at com.fico.service.login.loginservice.createSuccessactivity (loginservice.java:264)
at.force.service. .Loginservice.lambda $ executeParalleloporations $ 5 (loginservice.java:186)
... 7 общих кадров опущены < /p>
Это наш файл POM: < /p>

UTF-8
21
21
21
2024.0.0
3.2.2
6.6.0.Final
2.27.15
3.0.0
2.6.0
1.5.15
1.18.36



org.springframework.boot
spring-boot-starter-parent
3.4.1



com.fico.ngce.common.response
common-req-resp
1.0.1.initial


org.modelmapper
modelmapper
${modelmapper.version}


org.springframework.boot
spring-boot-starter-web


org.springframework.boot
spring-boot-starter-actuator


org.springframework.boot
spring-boot-devtools
runtime
true


org.projectlombok
lombok
${lombok.version}
provided


org.springframework.kafka
spring-kafka


org.apache.kafka
kafka-clients


org.springframework.cloud
spring-cloud-starter-stream-kafka




org.springframework.cloud
spring-cloud-starter-bus-kafka


org.apache.kafka
kafka-clients


software.amazon.msk
aws-msk-iam-auth




org.apache.kafka
kafka-clients
3.7.1



Подробнее здесь: https://stackoverflow.com/questions/794 ... t-be-found