верблюжья кафка по маршруту не засиживается - PullRequest
Новая
       16

верблюжья кафка по маршруту не засиживается

0 голосов
/ 21 декабря 2018

Я пытаюсь использовать kafka с верблюдом и настраиваю следующий маршрут: 

public class WorkflowEventConsumerRoute extends RouteBuilder {
    private static final String KAFKA_ENDPOINT =
         "kafka:payments-bus?brokers=localhost:9092";
    ...
    @Override
    public void configure() {
        from(KAFKA_ENDPOINT)
            .routeId(format(KAFKA_CONSUMER))
            .to("mock:end);
    }
}

Когда я запускаю приложение весенней загрузки, я вижу, что маршрут запускается, но сразу после этого он отключается без каких-либопричины, приведенные в журналах: 

2018-12-21 12:06:45.012  INFO 12184 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version : 2.0.1
2018-12-21 12:06:45.013  INFO 12184 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId : fa14705e51bd2ce5
2018-12-21 12:06:45.014  INFO 12184 --- [           main] o.a.camel.spring.SpringCamelContext      : Route: kafka-consumer started and consuming from: kafka://payments-bus?brokers=localhost%3A9092
2018-12-21 12:06:45.015  INFO 12184 --- [r[payments-bus]] o.a.camel.component.kafka.KafkaConsumer  : Subscribing payments-bus-Thread 0 to topic payments-bus
2018-12-21 12:06:45.015  INFO 12184 --- [           main] o.a.camel.spring.SpringCamelContext      : Total 1 routes, of which 1 are started
2018-12-21 12:06:45.015  INFO 12184 --- [           main] o.a.camel.spring.SpringCamelContext      : Apache Camel 2.23.0 (CamelContext: camel-1) started in 0.234 seconds
2018-12-21 12:06:45.019  INFO 12184 --- [           main] a.c.n.t.p.workflow.WorkflowApplication   : Started WorkflowApplication in 3.815 seconds (JVM running for 4.513)
2018-12-21 12:06:45.024  INFO 12184 --- [      Thread-10] o.a.camel.spring.SpringCamelContext      : Apache Camel 2.23.0 (CamelContext: camel-1) is shutting down

С другой стороны, если создать модульный тест и указать на одну и ту же конечную точку kafka, я могу прочитать содержимое темы kafka, используя экземпляр org.apache.camel.ConsumerTemplate.предоставляемый CamelTestSupport

В конечном итоге, если я заменяю конечную точку kafka в своем маршруте на activemq, маршрут начинается в порядке, и приложение остается в рабочем состоянии.

Очевидно, что я что-то упускаю, но не могу понятьчто.

Заранее благодарю за помощь.

1 Ответ

0 голосов
/ 21 декабря 2018

У вашего приложения с весенней загрузкой есть -web-starter или нет.Если нет, то вам следует включить верблюжий контроллер запуска, чтобы запустить загрузочное приложение.

В application.properties добавить 

 camel.springboot.main-run-controller = true
...