Потребительский код Python не работает на Google Cloud Platform + GKE - PullRequest
Новая
       78

Потребительский код Python не работает на Google Cloud Platform + GKE

0 голосов
/ 26 марта 2019

Я установил Confluent CP Charts на GKE от ЗДЕСЬ

Используя эти 2 команды, 

git clone https://github.com/confluentinc/cp-helm-charts.git

helm install cp-helm-charts

После успешной установки я могу подключиться к POD kafka-client, чтобы создавать и принимать сообщения с помощью команд.

Команда продюсера: 

kafka-console-producer --broker-list callous-octopus-cp-kafka-headless:9092 --topic callous-octopus-topic

Потребительская команда 

kafka-console-consumer --bootstrap-server 11.111.111.11:9092 --topic callous-octopus-topic --from-beginning

Но следующий код на python не печатает сообщения темы kafka 

from kafka import KafkaConsumer
from json import loads
consumer = KafkaConsumer(
    'callous-octopus-topic',
     bootstrap_servers=['11.111.111.11:9092'],
     auto_offset_reset='earliest',
     enable_auto_commit=True,
     group_id='my-group',
     value_deserializer=lambda x: loads(x.decode('utf-8')))
for message in consumer:
    message = message.value
    print(message)

Любые легенды здесь, пожалуйста, дайте мне знать, что мне здесь не хватает.

Приветствия

...