IBM Message Hub - 正常に動作してから数時間後にブローカでサポートされていないSASLハンドシェイクで失敗します（メカニズムPLAINで必要）

Question

次のアプリケーションはすべてのメッセージをコンソールに出力する簡単なコンシューマです。

#!/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機構で必要です）

Answer 1

ログに記載された時間にメッセージハブの停止が発生したため、それに関連する可能性があります。