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

Question

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

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

org.apache.camel.FailedToStartRouteException: Failed to start route route1 because of Route(route1)[From[amqp:queue:destinationName] -> [To[kafka:.

Если я не ошибаюсь, connectionFactory должен создаваться автоматически, если я передаю правильные свойства в файл application.properties.

Я прошел эту страницу, чтобы узнать возможные имена свойств - https://camel.apache.org/components/latest/amqp-component.html

и использовал следующие

camel.component.amqp.connection-factory = javax.jms.ConnectionFactory
camel.component.amqp.broker-url = localhost:6789

Но это не решит мою проблему. Может кто-нибудь предложить, какие свойства мне следует использовать, чтобы connectionFactory был легко доступен для меня?

Answer 1

Это просто относится к интерфейсу

camel.component.amqp.connection-factory = javax.jms.ConnectionFactory

Вместо этого он должен ссылаться на существующий заводской экземпляр, такой как

camel.component.amqp.connection-factory = #myFactory

, который вы можете настроить с помощью весенней загрузки @Bean аннотация стиль.