Теперь Обратная связь, если соединение работает - PullRequest
Новая
       20

Теперь Обратная связь, если соединение работает

0 голосов
/ 06 февраля 2020

Я пытаюсь создать простой клиент с пикафкой. Для этого мне нужны SSL-сертификаты. Клиент работает под RHEL 7 и Python 3.6.x Похоже, соединение работает, но я не получаю никаких отзывов или данных, только черный экран. Как я могу проверить соединение или получить сообщения об ошибках. 

#!/usr/bin/scl enable rh-python36 -- python3

from pykafka import KafkaClient, SslConfig

config = SslConfig(cafile='key/root_ca.crt',
                   certfile='key/cert.crt',  
                   keyfile='key/key.key',
                   password='xxxx') 

client = KafkaClient(hosts="xxxxxxx:9093", 
                        ssl_config=config)

print("topics", client.topics) 

topic = client.topics['xxxxxx']

consumer = topic.get_simple_consumer(
                    consumer_group="yyyyy",
                    auto_offset_reset=OffsetType.EARLIEST,
                    reset_offset_on_start=False
                    )

for message in consumer:
    if message is not None:
        print (message.offset, message.value)
...