Вызывается: java.lang.ClassNotFoundException: org.apache.kafka.clients.producer.Callback - PullRequest
Новая
       38

Вызывается: java.lang.ClassNotFoundException: org.apache.kafka.clients.producer.Callback

0 голосов
/ 18 мая 2019

Я пытаюсь настроить ведение журнала Apache Kafka для mule (mule server 3.9.1 и anypoint studio 6.5.2 в среде Windows в проекте mavenized, папка .m2 находится в моем classpath), следуя этому руководству (https://www.ricston.com/blog/logging-to-kafka-with-mule/):

"Log4j2 поставляется с приложением Kafka Appender из коробки - оно позволяет разработчикам направлять свои сообщения журнала в тему Kafka."

Я выполнил те же самые шаги, как описано итакже принял во внимание заявление об отказе от ответственности " ПРИМЕЧАНИЕ. Это не будет работать, если вы попробуете это в Studio. При запуске Mule сначала загружаются его классы, а затем все приложения " (имеет смысл ... сервер должен запускатьсяперед началом работы любых приложений).

В результате библиотека Kafka Clients должна присутствовать в classpath сервера при запуске, в противном случае вы получите несколько записей ERROR в журналах, и приложение будет нормально запускаться.

Я пытался разными способами получить его в classpath (также включил его в pom.xml, проект также строится нормально, но, как уже упоминалось в заявлении об отказе, во время выполнения происходит сбой со следующей ошибкой: 

INFO  2019-05-18 13:00:15,866 [WrapperListener_start_runner] org.mule.module.launcher.MuleDeploymentService:
**********************************************************************
* Started domain 'default'                                           *
**********************************************************************
INFO  2019-05-18 13:00:15,884 [WrapperListener_start_runner] org.mule.module.launcher.ArtifactArchiveInstaller: Exploding a Mule artifact archive: file:/C:/Mule/apps/mave
ntestproject.zip
INFO  2019-05-18 13:00:16,558 [WrapperListener_start_runner] org.mule.module.launcher.application.DefaultMuleApplication:
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
+ New app 'maventestproject'                               +
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
INFO  2019-05-18 13:00:16,572 [WrapperListener_start_runner] org.mule.module.launcher.MuleApplicationClassLoader: [maventestproject] Loading the following jars:
=============================
file:/C:/Mule/apps/maventestproject/lib/kafka-clients-0.10.2.1.jar
file:/C:/Mule/apps/maventestproject/lib/lz4-1.3.0.jar
file:/C:/Mule/apps/maventestproject/lib/snappy-java-1.1.2.6.jar
=============================

ERROR 2019-05-18 13:00:16,947 [WrapperListener_start_runner] org.mule.module.launcher.DefaultArchiveDeployer:
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
+ Failed to deploy artifact 'maventestproject', see below  +
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
java.lang.NoClassDefFoundError: org/apache/kafka/clients/producer/Callback
        at org.apache.logging.log4j.core.appender.mom.kafka.KafkaAppender$Builder.build(KafkaAppender.java:68) ~[log4j-core-2.8.2.jar:2.8.2]
        at org.apache.logging.log4j.core.appender.mom.kafka.KafkaAppender$Builder.build(KafkaAppender.java:53) ~[log4j-core-2.8.2.jar:2.8.2]
        at org.apache.logging.log4j.core.config.plugins.util.PluginBuilder.build(PluginBuilder.java:122) ~[log4j-core-2.8.2.jar:2.8.2]
        at org.apache.logging.log4j.core.config.AbstractConfiguration.createPluginObject(AbstractConfiguration.java:952) ~[log4j-core-2.8.2.jar:2.8.2]
        at org.apache.logging.log4j.core.config.AbstractConfiguration.createConfiguration(AbstractConfiguration.java:892) ~[log4j-core-2.8.2.jar:2.8.2]

В моей папке .m2 присутствует следующее: 

C:\Users\user\.m2\repository\org\apache\kafka\kafka-clients\0.10.2.1\kafka-clients-0.10.2.1

Как видно из логирования терминала, фляга также включена в проект.Но, к сожалению, при развертывании с anypoint studio или даже mule esb он по-прежнему жалуется на то, что класс не найден.
Я также добавил jar в путь к классам: 

C:\Users\user\.m2\repository\org\apache\kafka\kafka-clients\0.10.2.1\kafka-clients-0.10.2.1.jar

Также я попытался добавить файл jarна lib\boot и удалив мою папку m2, вернулись в зависимости и т. д., но безрезультатно.

Глядя на это часами.Любой совет, пожалуйста?

сводка:

  • сборка прошла нормально с классом Maven
  • , не найденным во время выполнения (но jar предоставляется в project и classpath, ..)
...