Ошибка запуска клиента Python Kafka, хотя потребитель работает - PullRequest
Новая
       60

Ошибка запуска клиента Python Kafka, хотя потребитель работает

0 голосов
/ 08 ноября 2018

Я использую клиентский пакет confluent_kafka версии 0.11.5 и Python 3.6.6 для взаимодействия с Apache Kafka. Получение сообщения об ошибке при опросе соединения потребителя в течение нескольких минут. Все еще в состоянии потреблять и обрабатывать сообщения правильно из подписанной темы. Кажется, что я получаю сообщение об ошибке / сбое только у некоторых брокеров, которых я использовал в соединении, но не у всех. Ошибка появляется быстрее при локальном запуске, чем в Kubernetes, но имеет тенденцию исчезать через некоторое время и затем возвращаться.

Потребительские опции: 

{
    'bootstrap.servers': kafka_brokers_sasl,
    'sasl.mechanisms': 'PLAIN',
     'security.protocol': 'SASL_SSL',
     'sasl.username': 'token',
     'sasl.password': api_key,
     'log.connection.close' : False,
     'client.id': 'kafka-python-console-sample-consumer',
     'group.id': 'kafka-python-console-sample-consumer',
     'default.topic.config': {
         'auto.offset.reset': 'earliest'
      }
}

Сообщение об ошибке: 

%3|1539683094.048|FAIL|kafka-python-console-sample-consumer#consumer-1| [thrd:sasl_ssl://kafka02-prod01.messagehub.services.eu-de.bluemix.net]: sasl_ssl://kafka02-prod01.messagehub.services.eu-de.bluemix.net:9093/1: Failed to initializeSASL authentication: SASL Handshake not supported by broker (required by mechanism PLAIN) 
%3|1539683094.048|ERROR|kafka-python-console-sample-consumer#consumer-1| [thrd:sasl_ssl://kafka02-prod01.messagehub.services.eu-de.bluemix.net]: sasl_ssl://kafka02-prod01.messagehub.services.eu-de.bluemix.net:9093/1: Failed to initialize SASL authentication: SASL Handshake not supported by broker (required by mechanism PLAIN)

Я прочитал несколько разных постов, но не могу найти решение, которое подходит мне. Как я могу избавиться от сообщения и убедиться, что все в порядке с моими соединениями с брокером?

...