Я создаю приложение, используя 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