Блог

Здравствуйте, у меня очень простой верблюжий маршрут (пытаюсь использовать и регистрировать сообщение темы Кафки):

 @Override
public void configure() throws Exception {
    super.configure();

    from(kafka())
            .routeId(INPUT_BROKER_ROUTE_ID)

            .log("KAFKA BODY ::: ${body}");
}

private static String kafka() {
    return new StringBuilder("kafka:")
            .append("{{kafka.topic}}")
            .append("?brokers=")
            .append("{{kafka.brokers}}")
            .append("amp;groupId=")
            .append("{{kafka.group.id}}")
            .append("amp;clientId=")
            .append("myClientId")
            .append("amp;autoOffsetReset=")
            .append("earliest")
            .append("amp;saslMechanism=")
            .append("PLAIN")
            .append("amp;securityProtocol=")
            .append(SASL_PLAINTEXT)
            .append("amp;saslJaasConfig=")
            .append(saslJaasConfig())
            .toString();
}

private static String saslJaasConfig() {
    return new StringBuilder(format("%s", PlainLoginModule.class.getCanonicalName()))
            .append(' ').append("required").append(' ')
            .append("username=")
            .append('"').append("{{kafka.username}}").append('"')
            .append(' ')
            .append("password=")
            .append('"').append("{{kafka.password}}").append('"')
            .append(';')
            .toString();
}
 

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

 11:37:27.064 INFO [Blueprint Event Dispatcher: 1] Successfully logged in.
11:37:27.067 WARN [Blueprint Event Dispatcher: 1] The configuration 'specific.avro.reader' was supplied but isn't a known config.
11:37:27.068 INFO [Blueprint Event Dispatcher: 1] Kafka version: 2.6.0
11:37:27.069 INFO [Blueprint Event Dispatcher: 1] Kafka commitId: 62abe01bee039651
11:37:27.069 INFO [Blueprint Event Dispatcher: 1] Kafka startTimeMs: 1624354647068
11:37:27.070 INFO [Blueprint Event Dispatcher: 1] Route: input-broker-route started and consuming from: kafka://test
11:37:27.070 INFO [Camel (integ-norauto-v1-input) thread #75 - KafkaConsumer[test]] Subscribing test-Thread 0 to topic test
11:37:27.071 INFO [Blueprint Event Dispatcher: 1] Total 1 routes, of which 1 are started
11:37:27.073 INFO [Camel (integ-norauto-v1-input) thread #75 - KafkaConsumer[test]] [Consumer clientId=myClientId, groupId=myGroupId] Subscribed to topic(s): test
11:37:27.073 INFO [Blueprint Event Dispatcher: 1] Apache Camel 3.7.4 (integ-norauto-v1-input) started in 38ms
 

Я провожу некоторые тесты и вижу, что даже если я укажу неправильное имя пользователя или пароль, ничего не произойдет (только при запуске на Karaf), похоже, что он не подключен

Я наконец обнаружил, что ошибка camel в LTS версии 3.7.4 устранена с помощью последней версии camel (3.10.0)…