我需要使用camel和kerberos认证协议将activemq消息路由到kafka（cloudera）。
activemq 5.15.4版
camel:2.21.1
Kafka客户端：1.1.0
服务器版本：apache/2.4.6（centos）
Kafka安全文档声明它只支持sasl d u明文和
用于kerberos的sasl\u ssl
另一方面，当我尝试在camel中使用sasl\u明文作为安全协议时，我在activemq启动期间遇到了一个错误。因此activemq将不会启动。
我从以下位置获取了最新的camel代码：https://github.com/apache/camel.git 它声明它只支持ssl和明文作为安全协议值。
我发现这个问题已经解决了：https://access.redhat.com/solutions/3364871 但我没有发现任何证据表明，这是工作在最新的 Camel 版本。
我的camel设置片段是：
<log message="Started The Producer Route" />
<to uri="kafka://10.100.70.00:9092?topic=MyEvents.s1.v1&brokers=10.100.70.00:9092&requestTimeoutMs=305000&retries=3&keySerializerClass=org.apache.kafka.common.serialization.ByteArraySerializer&saslMechanism=GSSAPI&serializerClass=org.apache.kafka.common.serialization.ByteArraySerializer&securityProtocol=SASL_PLAINTEXT&saslKerberosServiceName=kafka"/>我正在使用一个外部jaas配置文件。
camel真的不支持sasl\u明文吗？
1条答案
按热度按时间pwuypxnk1#
camel支持saslèu纯文本，因为它使用kafka客户端v1.1.0。问题是实际的安全参数没有传播到camel接口。这意味着参数在activemq启动期间无法识别。我已经开始讨论这个问题了。