以下应用程序是一个简单的消费者,它将所有消息打印到控制台。IBM消息中心 - 经过数小时的工作,很好,它通过代理不支持的SASL握手失败(机制PLAIN需要)
#!/usr/bin/env python
import confluent_kafka
consumer = confluent_kafka.Consumer({
'bootstrap.servers': 'kafka05-prod01.messagehub.services.us-south.bluemix.net:9093,kafka03-prod01.messagehub.services.us-south.bluemix.net:9093,kafka01-prod01.messagehub.services.us-south.bluemix.net:9093,kafka04-prod01.messagehub.services.us-south.bluemix.net:9093,kafka02-prod01.messagehub.services.us-south.bluemix.net:9093',
'security.protocol': 'SASL_SSL',
'sasl.mechanisms': 'PLAIN',
'sasl.username': 'XXX',
'sasl.password': 'XXX',
'api.version.request': True,
'client.id': 'consumer01',
'group.id': 'group01',
})
consumer.subscribe(['logs'])
while True:
msg = consumer.poll(1)
if msg is not None and msg.error() is None:
print(msg.value().decode('utf-8'))
在开始时它工作正常。几个小时后,我看到以下错误消息。一旦我重新启动脚本,它再次正常工作。
^C%3 | 1504028772.615 | FAIL | consumer01#consumer-1 | [thrd:sasl_ssl://kafka08-prod01.messagehub.services.us-south.bluemix。]:sasl_ssl://kafka08-prod01.messagehub.services.us-south.bluemix.net:9093/7:未能初始化SASL认证:代理不支持SASL握手(机制PLAIN要求) %3 | 1504028772.615 | ERROR | consumer01#consumer-1 | [thrd:sasl_ssl://kafka08-prod01.messagehub.services.us-south.bluemix。]:sasl_ssl://kafka08-prod01.messagehub.services.us-south.bluemix.net:9093/7:未能初始化SASL认证:代理不支持SASL握手(机制PLAIN要求)
只需添加到Simon所说的内容,以下是指向Bluemix状态页面的链接:https://console.bluemix.net/status?tag = platform,runtimes ,services,ibm :yp:us-south,ibm :yp:eu-gb,ibm:yp:eu-de,ibm:yp:au-syd,experimental_services&view = n:i –
谢谢Simon&Bill为您的快速响应... –