Исключение схемы провайдера не определено в приложении SpringBoot, использующем верблюда Apache для передачи сообщений из AMQP в Kafka - PullRequest
Новая
       75

Исключение схемы провайдера не определено в приложении SpringBoot, использующем верблюда Apache для передачи сообщений из AMQP в Kafka

0 голосов
/ 16 марта 2020

Я создаю приложение, используя Apache Camel для передачи сообщений из AMQP в Kafka. Я думал о том, чтобы создать его как отдельное приложение Springboot, потому что было доступно много стартеров. Я использовал camel-spring-boot-starter, camel-amqp-starter и camel-kafka-starter. И создал маршрут как 

@Component
public class QpidToKafkaRoute extends RouteBuilder {
public void configure() throws Exception {
  from("amqp:queue:destinationName")
          .to("kafka:topic");
}
}

Когда я запустил это приложение, я получил следующее исключение - 

java.io.IOException: No Provider scheme specified.
at org.apache.qpid.jms.provider.ProviderFactory.findProviderFactory(ProviderFactory.java:149) [qpid-jms-client-0.48.0.jar:na]
at org.apache.qpid.jms.provider.ProviderFactory.findProviderFactory(ProviderFactory.java:131) [qpid-jms-client-0.48.0.jar:na]
at org.apache.qpid.jms.provider.ProviderFactory.create(ProviderFactory.java:102) [qpid-jms-client-0.48.0.jar:na]
at org.apache.qpid.jms.provider.ProviderFactory.create(ProviderFactory.java:82) [qpid-jms-client-0.48.0.jar:na]

Здесь проверяется код -

https://github.com/prashantbhardwaj/camel-springboot-qpid-kafka

...