Протокол безопасности Camel-Kafka SASL_PLAINTEXT не поддерживается - PullRequest
Новая
       22

Протокол безопасности Camel-Kafka SASL_PLAINTEXT не поддерживается

0 голосов
/ 24 июня 2018

Мне нужно направить сообщения ActiveMQ на Кафку (Cloudera), используя Camel с использованием протокола аутентификации Kerberos.

  • ActiveMQ v5.15.4
  • Camel: 2.21.1
  • Клиенты Kafka: 1.1.0
  • Версия сервера: Apache / 2.4.6 (CentOS)

В документации Kafka Security говорится, что она поддерживает только SASL_PLAINTEXT и
SASL_SSL для Kerberos

С другой стороны, когда я пытаюсь использовать SASL_PLAINTEXT для протокола безопасности в Camel, я получаю ошибку во время запуска ActiveMQ.В результате ActiveMQ не запускается.

Я взял последний верблюжий код из: https://github.com/apache/camel.git, и в нем говорится, что он поддерживает только SSL и PLAINTEXT в качестве значений протоколов безопасности.

Я нашел эту решенную проблему: https://access.redhat.com/solutions/3364871, но я не нашел никаких доказательств того, что это работает в последней версии Camel.

Настройка My Camelфрагмент: 

<log message="Started The Producer Route" />
<to uri="kafka://10.100.70.00:9092?topic=MyEvents.s1.v1&amp;brokers=10.100.70.00:9092&amp;requestTimeoutMs=305000&amp;retries=3&amp;keySerializerClass=org.apache.kafka.common.serialization.ByteArraySerializer&amp;saslMechanism=GSSAPI&amp;serializerClass=org.apache.kafka.common.serialization.ByteArraySerializer&amp;securityProtocol=SASL_PLAINTEXT&amp;saslKerberosServiceName=kafka"/>

Я использую внешний файл конфигурации Jaas.

Правда ли, что Camel не поддерживает SASL_PLAINTEXT ?

1 Ответ

0 голосов
/ 27 июня 2018

Camel поддерживает SASL_PLAINTEXT , поскольку использует клиент Kafka v1.1.0.Проблема в том, что фактический параметр безопасности не распространяется на интерфейс Camel.Это означает, что параметр не распознается во время запуска ActiveMQ.Я открыл выпуск для этой проблемы.

...