时间戳

首页 > 解决方案 > 即使消费者工作，Python Kafka 客户端也会触发错误

python - 即使消费者工作，Python Kafka 客户端也会触发错误

问题描述

我正在使用 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)

我已经阅读了多个不同的帖子，但找不到适合我的解决方案。如何摆脱该消息并确保我的代理连接没有问题？

标签： pythonapache-kafkaconfluent-platform

解决方案

推荐阅读