我正在尝试使用合流的kafka python从bluemix上的消息中心的一个主题获取消息。我的代码在下面，但有些东西不工作。主题和消息中心已启动并正在运行，因此代码中可能有一些内容。

from confluent_kafka import Producer, KafkaError, Consumer

consumer_settings = {
'bootstrap.servers': 'broker-url-here',
'group.id': 'mygroup',
'default.topic.config': {'auto.offset.reset': 'smallest'},
'sasl.mechanisms': 'PLAIN',
'security.protocol': 'ssl',
'sasl.username': 'username-here',
'sasl.password': 'password-here',
}

c = Consumer(**consumer_settings)
c.subscribe(['topic-here'])

running = True

while running:
    msg = c.poll()
    if msg.error():
        print("Error while retrieving message")
        c.close()
        sys.exit(10)
    elif (msg is not None):
        for x in msg:
            print(x)
    else:
        sys.exit(10)

当我运行代码时，它似乎被困在 msg = c.poll() . 所以我猜要么是无法连接，要么是无法检索消息。凭证本身是正确的。