Я пытаюсь получить сообщения из темы в концентраторе сообщений на bluemix, используя Confluent Kafka Python. Мой код находится ниже, но что-то не работает. Тема и концентратор сообщений запущены и работают, так что, вероятно, что-то с кодом.
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()
. Поэтому я предполагаю, что либо не удается подключиться, либо не удается получить сообщения. Сами реквизиты правильные.