无法使用Karaf 4.3.1和Camel 3.7.4从Kafka主题中消费

Question

你好我有一个非常简单的骆驼路线(尝试消费和记录Kafka主题消息):

@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("&groupId=")
            .append("{{kafka.group.id}}")
            .append("&clientId=")
            .append("myClientId")
            .append("&autoOffsetReset=")
            .append("earliest")
            .append("&saslMechanism=")
            .append("PLAIN")
            .append("&securityProtocol=")
            .append(SASL_PLAINTEXT)
            .append("&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();
}

如果我在此路由上运行单元测试，我会看到主题消息，但当我部署此捆绑包时，我没有从主题中收到任何消息，也没有错误，Karaf只是向我显示此日志：

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上运行时），看起来它没有连接。

Answer 1

我终于发现LTS 3 . 7 . 4版本的camel bug是通过使用最新的camel版本(3.10.0)解决的...